Surveillez, recevez et envoyez des événements avec Azure Event Hubs et Azure Logic AppsMonitor, receive, and send events with Azure Event Hubs and Azure Logic Apps

Cet article explique comment vous pouvez surveiller et gérer les événements envoyés à Azure Event Hubs depuis une application logique à l’aide du connecteur Azure Event Hubs.This article shows how you can monitor and manage events sent to Azure Event Hubs from inside a logic app with the Azure Event Hubs connector. De cette façon, vous pouvez créer des applications logiques qui automatisent les tâches et les flux de travail pour vérifier, envoyer et recevoir des événements à partir de votre hub d’événements.That way, you can create logic apps that automate tasks and workflows for checking, sending, and receiving events from your Event Hub. Pour obtenir des informations techniques spécifiques aux connecteurs, consultez la documentation de référence du connecteur Azure Event Hubs.For connector-specific technical information, see the Azure Event Hubs connector reference.

PrérequisPrerequisites

Vérifier les autorisations et obtenir la chaîne de connexionCheck permissions and get connection string

Pour vous assurer que votre application logique peut accéder à votre hub d’événements, vérifiez vos autorisations et obtenez la chaîne de connexion pour votre espace de noms Event Hubs.To make sure that your logic app can access your Event Hub, check your permissions and get the connection string for your Event Hubs namespace.

  1. Connectez-vous au Portail Azure.Sign in to the Azure portal.

  2. Accédez à votre espace de noms Event Hubs, et non à un hub d’événements spécifique.Go to your Event Hubs namespace, not a specific Event Hub.

  3. Dans le menu de l’espace de noms, sous Paramètres, sélectionnez Stratégies d’accès partagé.On the namespace menu, under Settings, select Shared access policies. Sous Revendications, vérifiez que vous disposez des autorisations Gérer pour cet espace de noms.Under Claims, check that you have Manage permissions for that namespace.

    Gérer les autorisations pour votre espace de noms Event Hubs

  4. Si vous souhaitez pouvoir entrer manuellement vos informations de connexion par la suite, obtenez la chaîne de connexion pour votre espace de noms Event Hubs.If you want to later manually enter your connection information, get the connection string for your Event Hubs namespace.

    1. Sous Stratégie, choisissez RootManageSharedAccessKey.Under Policy, choose RootManageSharedAccessKey.

    2. Trouvez la chaîne de connexion de la clé primaire.Find your primary key's connection string. Choisissez le bouton Copier et enregistrez la chaîne de connexion pour l’utiliser plus tard.Choose the copy button, and save the connection string for later use.

      Copier la chaîne de connexion d’espace de noms Event Hubs

      Conseil

      Pour vérifier que votre chaîne de connexion est bien associée à votre espace de noms Event Hubs ou à un hub d’événements spécifique, assurez-vous que la chaîne de connexion ne contient pas le paramètre EntityPath .To confirm whether your connection string is associated with your Event Hubs namespace or with a specific event hub, make sure the connection string doesn't have the EntityPath parameter. Si vous trouvez ce paramètre, la chaîne de connexion est dédiée à une « entité » Event Hub spécifique et ne peut pas être utilisée avec votre application logique.If you find this parameter, the connection string is for a specific Event Hub "entity" and is not the correct string to use with your logic app.

  5. Passez maintenant à Ajouter un déclencheur Event Hubs ou Ajouter une action Event Hubs.Now continue with Add an Event Hubs trigger or Add an Event Hubs action.

Ajouter un déclencheur Event HubsAdd Event Hubs trigger

Dans Azure Logic Apps, chaque application logique doit démarrer avec un déclencheur, qui s’active lorsqu’un événement spécifique se produit ou lorsqu’une condition particulière est remplie.In Azure Logic Apps, every logic app must start with a trigger, which fires when a specific event happens or when a specific condition is met. Chaque fois que le déclencheur s’active, le moteur Logic Apps crée une instance d’application logique et lance l’exécution du flux de travail de votre application.Each time the trigger fires, the Logic Apps engine creates a logic app instance and starts running your app's workflow.

Cet exemple montre comment vous pouvez démarrer un flux de travail d’application logique lorsque de nouveaux événements sont envoyés à votre hub d’événements.This example shows how you can start a logic app workflow when new events are sent to your Event Hub.

  1. Dans le portail Azure ou Visual Studio, créez une application logique vide, qui ouvre le Concepteur d'applications logiques.In the Azure portal or Visual Studio, create a blank logic app, which opens Logic Apps Designer. Cet exemple utilise le portail Azure.This example uses the Azure portal.

  2. Dans la zone de recherche, entrez « hubs d’événements » en tant que filtre.In the search box, enter "event hubs" as your filter. Dans la liste des déclencheurs, sélectionnez ce déclencheur : When events are available in Event Hub (Lorsque les événements sont disponibles dans un hub Event Hubs) - Event HubsFrom the triggers list, select this trigger: When events are available in Event Hub - Event Hubs

    Sélectionner le déclencheur

  3. Si vous êtes invité à entrer les informations de connexion, créez votre connexion Event Hubs maintenant.If you're prompted for connection details, create your Event Hubs connection now.

  4. Dans le déclencheur, fournissez des informations sur l’Event Hub que vous souhaitez surveiller.In the trigger, provide information about the Event Hub that you want to monitor. Pour plus de propriétés, ouvrez la liste Ajouter un nouveau paramètre.For more properties, open the Add new parameter list. La sélection d'un paramètre ajoute cette propriété à la carte de déclencheur.Selecting a parameter adds that property to the trigger card.

    Propriétés de déclencheur

    PropriétéProperty ObligatoireRequired DescriptionDescription
    Nom de l’Event HubEvent Hub name OUIYes Nom du hub Event Hubs que vous souhaitez surveillerThe name for the Event Hub that you want to monitor
    Type de contenuContent type NonNo Type de contenu de l’événement.The event's content type. Par défaut, il s’agit de application/octet-stream.The default is application/octet-stream.
    Nom du groupe de consommateursConsumer group name NonNo Nom du groupe de consommateurs Event Hub pour la lecture d’événements.The name for the Event Hub consumer group to use for reading events. Si ce champ n’est pas spécifié, le groupe de consommateurs par défaut est utilisé.If not specified, the default consumer group is used.
    Nombre d’événements maximumMaximum events count NonNo Nombre maximal d’événements.The maximum number of events. Le déclencheur retourne entre 1 et le nombre d’événements spécifié par cette propriété.The trigger returns between one and the number of events specified by this property.
    IntervalleInterval OUIYes Nombre entier positif qui décrit la fréquence à laquelle le flux de travail s’exécute en fonction de la fréquenceA positive integer that describes how often the workflow runs based on the frequency
    FréquenceFrequency OUIYes Unité de temps à utiliser pour la récurrenceThe unit of time for the recurrence

    Propriétés supplémentairesAdditional properties

    PropriétéProperty ObligatoireRequired DescriptionDescription
    Schéma du contenuContent schema NonNo Schéma du contenu au format JSON pour les événements qui sont lus à partir de l’Event Hub.The JSON content schema for the events to read from the Event Hub. Par exemple, si vous spécifiez le schéma de contenu, vous pouvez déclencher l'application logique uniquement pour les événements qui correspondent au schéma.For example, if you specify the content schema, you can trigger the logic app for only those events that match the schema.
    Clé de partition minimumMinimum partition key NonNo Entrez l’ID de partition minimum à lire.Enter the minimum partition ID to read. Par défaut, toutes les partitions sont lues.By default, all partitions are read.
    Clé de partition maximumMaximum partition key NonNo Entrez l’ID de partition maximum à lire.Enter the maximum partition ID to read. Par défaut, toutes les partitions sont lues.By default, all partitions are read.
    Fuseau horaireTime zone NonNo S’applique uniquement quand vous spécifiez une heure de début, car ce déclencheur n’accepte pas le décalage UTC.Applies only when you specify a start time because this trigger doesn't accept UTC offset. Sélectionnez le fuseau horaire à appliquer.Select the time zone that you want to apply.

    Pour plus d’informations, consultez Créer et exécuter des tâches et des workflows récurrents avec Azure Logic Apps.For more information, see Create and run recurring tasks and workflows with Azure Logic Apps.

    Heure de débutStart time NonNo Fournissez une heure de début au format suivant :Provide a start time in this format:

    AAAA-MM-JJThh:mm:ss si vous sélectionnez un fuseau horaireYYYY-MM-DDThh:mm:ss if you select a time zone

    -ou--or-

    AAAA-MM-JJThh:mm:ssZ si vous ne sélectionnez pas de fuseau horaireYYYY-MM-DDThh:mm:ssZ if you don't select a time zone

    Pour plus d’informations, consultez Créer et exécuter des tâches et des workflows récurrents avec Azure Logic Apps.For more information, see Create and run recurring tasks and workflows with Azure Logic Apps.

  5. Une fois terminé, dans la barre d’outils du concepteur, choisissez Enregistrer.When you're done, on the designer toolbar, choose Save.

  6. Continuez maintenant à ajouter une ou plusieurs actions à votre application logique pour les tâches à effectuer avec les résultats du déclencheur.Now continue adding one or more actions to your logic app for the tasks you want to perform with the trigger results.

    Par exemple, pour filtrer les événements basés sur une valeur spécifique, telle qu’une catégorie, vous pouvez ajouter une condition pour que l’action Envoyer un événement envoie uniquement les événements qui répondent à votre condition.For example, to filter events based on a specific value, such as a category, you can add a condition so that the Send event action sends only the events that meet your condition.

Notes

Tous les déclencheurs Event Hub sont des déclencheurs d’interrogation longue, ce qui signifie que lorsqu’un déclencheur est activé, il traite tous les événements, puis attend 30 secondes le temps qu’un plus grand nombre d’événements s’affichent dans votre hub d’événements.All Event Hub triggers are long-polling triggers, which means that when a trigger fires, the trigger processes all the events and then waits for 30 seconds for more events to appear in your Event Hub. Si aucun événement n’est reçu dans les 30 secondes, l’exécution du déclencheur est ignorée.If no events are received in 30 seconds, the trigger run is skipped. Dans le cas contraire, le déclencheur poursuit la lecture des événements jusqu’à ce que votre hub d’événements soit vide.Otherwise, the trigger continues reading events until your Event Hub is empty. La prochaine interrogation de déclencheur est basée sur l’intervalle de récurrence que vous spécifiez dans les propriétés du déclencheur.The next trigger poll happens based on the recurrence interval that you specify in the trigger's properties.

Ajouter une action Event HubsAdd Event Hubs action

Dans Azure Logic Apps, une action est une étape de votre flux de travail qui suit un déclencheur ou une autre action.In Azure Logic Apps, an action is a step in your workflow that follows a trigger or another action. Pour cet exemple, l’application logique démarre avec un déclencheur Event Hubs qui recherche de nouveaux événements dans votre hub d'événements.For this example, the logic app starts with an Event Hubs trigger that checks for new events in your Event Hub.

  1. Dans le portail Azure ou Visual Studio, ouvrez votre application logique dans le Concepteur d’applications logiques.In the Azure portal or Visual Studio, open your logic app in Logic Apps Designer. Cet exemple utilise le portail Azure.This example uses the Azure portal.

  2. Sous le déclencheur ou l’action, choisissez Nouvelle étape.Under the trigger or action, choose New step.

    Pour ajouter une action entre des étapes, déplacez votre souris sur la flèche de connexion.To add an action between existing steps, move your mouse over the connecting arrow. Cliquez sur le signe plus ( + ) qui s’affiche, puis sélectionnez Ajouter une action.Choose the plus sign (+) that appears, and then select Add an action.

  3. Dans la zone de recherche, entrez « hubs d’événements » en tant que filtre.In the search box, enter "event hubs" as your filter. Dans la liste des actions, sélectionnez cette action : Envoyer un événement - Event HubsFrom the actions list, select this action: Send event - Event Hubs

    Sélectionner l’action « Envoyer un événement »

  4. Si vous êtes invité à entrer les informations de connexion, créez votre connexion Event Hubs maintenant.If you're prompted for connection details, create your Event Hubs connection now.

  5. Dans l'action, fournissez des informations sur les événements que vous souhaitez envoyer.In the action, provide information about the events that you want to send. Pour plus de propriétés, ouvrez la liste Ajouter un nouveau paramètre.For more properties, open the Add new parameter list. La sélection d'un paramètre ajoute cette propriété à la carte action.Selecting a parameter adds that property to the action card.

    Sélectionnez le nom du hub d’événements et fournissez le contenu de l’événement

    PropriétéProperty ObligatoireRequired DescriptionDescription
    Nom de l’Event HubEvent Hub name OUIYes Event Hub où vous voulez envoyer l’événementThe Event Hub where you want to send the event
    ContenuContent NonNo Le contenu pour l’événement que vous souhaitez envoyerThe content for the event you want to send
    PropriétésProperties NonNo Les valeurs et les propriétés de l’application à envoyerThe app properties and values to send
    Clé de partitionPartition key NonNo ID partition auquel envoyer l’événementThe partition ID for where to send the event

    Par exemple, vous pouvez envoyer la sortie de votre déclencheur Event Hubs à un autre Event Hub :For example, you can send the output from your Event Hubs trigger to another Event Hub:

    Envoyer un exemple d’événement

  6. Une fois terminé, dans la barre d’outils du concepteur, choisissez Enregistrer.When you're done, on the designer toolbar, choose Save.

Se connecter à votre hub d'événementsConnect to your Event Hub

Pour que votre application logique puisse accéder à tout service, vous devez créer une connexion entre votre application logique et ce service.Before your logic app can access any service, you must create a connection between your logic app and that service. Si vous n’avez pas créé cette connexion, vous êtes invité à fournir des informations de connexion lorsque vous ajoutez un déclencheur ou une action pour ce service vers votre application logique.If you didn't previously create this connection, you're prompted for connection information when you add a trigger or action for that service to your logic app. Le Concepteur d’applications logiques vous permet de créer facilement cette connexion, directement à partir de votre application logique.The Logic Apps Designer provides an easy way for you to create this connection directly from your logic app.

  1. Lorsque vous êtes invité à entrer des informations de connexion, fournissez les précisions suivantes :When you're prompted for connection information, provide these details:

    PropriétéProperty ObligatoireRequired ValueValue DescriptionDescription
    Nom de connexionConnection Name OUIYes <connection-name><connection-name> Nom à créer pour votre connexionThe name to create for your connection
    Espace de noms Event HubsEvent Hubs Namespace OUIYes <event-hubs-namespace><event-hubs-namespace> Sélectionnez l’espace de noms Event Hubs que vous souhaitez utiliser.Select the Event Hubs namespace you want to use.

    Par exemple :For example:

    Créer une connexion de hub d’événements

    Pour entrer manuellement la chaîne de connexion, sélectionnez Entrer manuellement les informations de connexion.To manually enter the connection string, select Manually enter connection information. Découvrez comment trouver votre chaîne de connexion.Learn how to find your connection string.

  2. Sélectionnez la stratégie Event Hubs à utiliser, si elle n’est pas déjà sélectionnée.Select the Event Hubs policy to use, if not already selected. Cliquez sur Créer.Choose Create.

    Créer une connexion de hub d’événements, partie 2

  3. Après avoir créé votre connexion, poursuivez avec Ajouter un déclencheur Event Hubs ou Ajouter une action Event Hubs.After you create your connection, continue with Add Event Hubs trigger or Add Event Hubs action.

Référence de connecteurConnector reference

Pour plus d’informations techniques, notamment sur les déclencheurs, les actions et les limites, comme décrit dans le fichier OpenAPI (anciennement Swagger) du connecteur, consultez la page de référence du connecteur.For technical details, such as triggers, actions, and limits, as described by the connector's OpenAPI (formerly Swagger) file, see the connector's reference page.

Étapes suivantesNext steps

En savoir plus sur les autres connecteurs d’applications logiquesLearn about other Logic Apps connectors