Accéder au contenu principal Passer au contenu complémentaire

Publier un message dans une instance d'Azure Event Hubs

Ce scénario a pour objectif de vous aider à configurer et à utiliser des connecteurs dans un pipeline. Ce scénario doit être adapté en fonction de votre environnement et de votre cas d'utilisation.

Exemple de pipeline créé en suivant les instructions ci-dessous.

Avant de commencer

Procédure

  1. Cliquez sur Datasets > Drop a file or browse.
  2. Parcourez votre système jusqu'au fichier local_file-to-azure_event_hubs.csv et sélectionnez-le.
  3. Renommez-le par exemple Baltimore restaurants.
  4. Cliquez sur Connections (Connexions) > Add connection (Ajouter une connexion).
  5. Dans le panneau qui s'ouvre, sélectionnez le type de connexion à créer.

    Exemple

    Azure EventHubs
  6. Sélectionnez votre moteur dans la liste Engine.
    Note InformationsRemarque :
    • Il est recommandé d'utiliser Moteur distant Gen2 plutôt que Moteur Cloud pour le design pour un traitement avancé des données.
    • Si aucun Moteur distant Gen2 n'a été créé depuis Talend Management Console ou s'il existe mais semble indisponible, ce qui signifie qu'il n'est pas en cours de fonctionnement, vous ne pourrez pas sélectionner de type de connexion (Connection type) dans la liste ou sauvegarder la nouvelle connexion.
    • Les types de connexion disponibles dépendent du moteur sélectionné.
  7. Sélectionnez le type de connexion à créer.
    Ici, sélectionnez Azure Event Hubs.
  8. Renseignez les propriétés de la connexion pour accéder à vos ressources de services Azure (points de terminaison, clés de signature d'accès partagé), comme décrit dans Propriétés Azure Event Hubs, vérifiez la connexion et cliquez sur Add dataset (Ajouter un jeu de données).
  9. Dans le panneau Add a new dataset, nommez votre jeu de données. Dans cet exemple, le hub Event Hub baltimore-restaurants actuellement vide sera utilisé pour publier les données relatives aux restaurants de Baltimore.

    Exemple

    Configuration d'un nouveau jeu de données Azure Event Hubs.
  10. Nommez votre jeu de données, Restaurant Event Hub par exemple.
  11. Cliquez sur Validate (Valider) pour sauvegarder votre jeu de données.
  12. Cliquez sur Add pipeline (Ajouter un pipeline) dans la page Pipelines. Votre nouveau pipeline s’ouvre.
  13. Donnez-lui un nom significatif.

    Exemple

    From local file to Azure Event Hubs - publish an event
  14. Cliquez sur ADD SOURCE et sélectionnez votre jeu de données source, Baltimore restaurants dans le panneau qui s'ouvre.
  15. Cliquez sur add processor (ajouter un processeur) et ajoutez un processeur Strings (Chaînes de caractères) au pipeline, afin de modifier la casse de certains enregistrements. Le panneau de configuration s'ouvre.
  16. Donnez un nom significatif au processeur.

    Exemple

    change case of police district records
  17. Configurez le processeur :
    1. Sélectionnez Change to title case dans la liste Function name puisque vous souhaitez changer la casse des enregistrements pour la passer de majuscules à casse de titre.
    2. Sélectionnez .police_disctrict dans la liste Fields to process, car vous souhaitez appliquer ce changement aux valeurs de ces enregistrements spécifiques.
  18. Cliquez sur Save (Sauvegarder) pour sauvegarder votre configuration.
  19. (Facultatif) Consultez l'aperçu du processeur pour voir les données après le changement de casse.
    Dans l'aperçu de données de sortie (Output), la casse des données relatives au district de la police est passée de lettres capitales à uniquement les premières lettres en capitales.
  20. Cliquez sur l'élément ADD DESTINATION dans le pipeline pour ouvrir le panneau vous permettant de sélectionner le hub Azure Event Hubs dans lequel vos données de sortie seront chargées, Restaurant Event Hub.
  21. Dans l'onglet Configuration de la destination, le modèle Round-Robin est le type de partition (Partition Type) utilisé par défaut lors de la publication d'un événement, mais vous pouvez spécifier une clé de partition ou un ID de partition répondant à votre usage.
  22. Dans la barre d'outils en haut de Talend Cloud Pipeline Designer, cliquez sur le bouton Run (Exécuter) pour ouvrir le panneau vous permettant de sélectionner votre profil d'exécution.
  23. Sélectionnez dans la liste votre profil d'exécution (pour plus d'informations, consultez Profils d'exécution), puis cliquez sur Run (Exécuter) pour exécuter votre pipeline.

Résultats

Votre pipeline est en cours d'exécution, les données des restaurants de Baltimore provenant de votre fichier local sont en cours de traitement et le flux de sortie est envoyé au hub Azure Event Hubs baltimore-restaurants défini :

Dans Azure Event Hubs, 300 messages ont été reçus au cours de la dernière heure, ce qui représente 25,78 kilooctets entrants.

Que faire ensuite

Une fois l'événement publié, vous pouvez consommer les messages dans un autre pipeline et les utiliser comme source dans Azure Event Hub :

Un nouveau pipeline dont la source contient les données relatives aux messages concernant les restaurants provenant du pipeline de destination précédent.

Cette page vous a-t-elle aidé ?

Si vous rencontrez des problèmes sur cette page ou dans son contenu – une faute de frappe, une étape manquante ou une erreur technique – faites-le-nous savoir.

Laissez vos commentaires ici