Condividi tramite


Connettersi a un hub eventi dai flussi di lavoro in App per la logica di Azure

Si applica a: App per la logica di Azure (A consumo)

Il connettore Hub eventi di Azure consente di connettere i flussi di lavoro dell'app per la logica agli hub eventi in Azure. È quindi possibile fare in modo che i flussi di lavoro monitorino e gestiscano gli eventi inviati a un hub eventi. Ad esempio, il flusso di lavoro può controllare, inviare e ricevere eventi dall'hub eventi. Questo articolo fornisce una guida introduttiva all'uso del connettore di Hub eventi di Azure illustrando come connettersi a un hub eventi e aggiungere un trigger o un'azione di Hub eventi al flusso di lavoro.

Per altre informazioni su Hub eventi di Azure o App per la logica di Azure, vedere Che cos'è Hub eventi di Azure o Che cos'è App per la logica di Azure.

Operazioni disponibili

Per tutte le operazioni e altre informazioni tecniche, ad esempio proprietà, limiti e così via, vedere la pagina di riferimento del connettore di Hub eventi.

Prerequisiti

Controllare le autorizzazioni e ottenere la stringa di connessione

Per assicurarsi che il flusso di lavoro possa accedere all'hub eventi, controllare le autorizzazioni e quindi ottenere la stringa di connessione per lo spazio dei nomi dell'hub eventi.

  1. Nel portale di Azure passare allo spazio dei nomi di Hub eventi, non a un hub eventi specifico.

  2. Nel menu dello spazio dei nomi, selezionare Criteri di accesso condivisi in Impostazioni. Nella colonna Attestazioni verificare di disporre almeno delle autorizzazioni di gestione per tale spazio dei nomi.

    Screenshot che mostra il portale di Azure, lo spazio dei nomi di Hub eventi e le autorizzazioni

  3. Se si vogliono immettere in un secondo momento le informazioni di connessione manualmente, ottenere la stringa di connessione per lo spazio dei nomi di Hub eventi.

    1. Nella colonna Criteri selezionare RootManageSharedAccessKey.

    2. Trovare la stringa di connessione della chiave primaria. Copiare e salvare la stringa di connessione per un uso successivo.

      Screenshot che mostra la stringa di connessione della chiave primaria con il pulsante copia selezionato.

      Suggerimento

      Per verificare se la stringa di connessione è associata allo spazio dei nomi di Hub eventi o a un hub eventi specifico, assicurarsi che nella stringa non sia presente il parametro EntityPath. Se questo parametro è presente, la stringa di connessione è per un'"entità" hub eventi specifica e non è la stringa corretta da usare con il flusso di lavoro.

Creare una connessione a Hub eventi

Quando si aggiunge un trigger o un'azione di Hub eventi per la prima volta, viene richiesto di creare una connessione all'hub eventi.

  1. Quando richiesto, scegliere una delle opzioni seguenti:

    • Specificare le informazioni seguenti sulla connessione:

      Proprietà Richiesto Valore Descrizione
      Nome connessione <nome connessione> Nome creato per la connessione
      Spazio dei nomi dell'Hub eventi <spazio dei nomi di hub eventi> Selezionare lo spazio dei nomi di Hub eventi da usare.
    • Per immettere manualmente la stringa di connessione salvata in precedenza, selezionare Immettere manualmente le informazioni di connessione. Leggere come trovare la stringa di connessione.

  2. Selezionare i criteri di Hub eventi da usare, se non è già selezionato e quindi selezionare Crea.

    Screenshot che mostra le informazioni di connessione fornite con l'opzione

  3. Dopo aver creato la connessione, continuare con Aggiungere un trigger per Hub eventi oppure Aggiungere un'azione per Hub eventi.

Aggiungere un trigger per Hub eventi

In App per la logica di Azure ogni flusso di lavoro deve iniziare con un trigger, che viene attivato quando viene soddisfatta una condizione specifica. Ogni volta che il trigger viene attivato, il servizio App per la logica crea un'istanza del flusso di lavoro e avvia l'esecuzione dei passaggi nel flusso di lavoro.

I passaggi seguenti descrivono il modo generale per aggiungere un trigger, ad esempio Quando gli eventi sono disponibili nell'hub eventi. Questo esempio illustra come aggiungere un trigger che verifica la presenza di nuovi eventi nell'hub eventi e avvia un'esecuzione del flusso di lavoro quando esistono nuovi eventi.

  1. In Progettazione app per la logica aprire il flusso di lavoro dell'app per la logica vuota, se non è già aperto.

  2. Nella casella di ricerca dell'operazione immettere event hubs. Nell'elenco dei trigger selezionare il trigger denominato Quando gli eventi sono disponibili nell'hub eventi.

    Selezionare il trigger

  3. Se viene richiesto di creare una connessione all'hub eventi, specificare le informazioni di connessione richieste.

  4. Nel trigger fornire informazioni sull'hub eventi che si vuole monitorare, ad esempio:

    Proprietà Richiesto Descrizione
    Nome hub eventi Nome dell'hub eventi da monitorare
    Tipo contenuto No Tipo di contenuto dell'evento. Il valore predefinito è application/octet-stream.
    Nome gruppo di consumer No Nome del gruppo di consumer di Hub eventi da usare per la lettura degli eventi. Se non specificato, viene usato il gruppo di consumer predefinito.
    Numero massimo di eventi No Numero massimo di eventi. Il trigger restituisce un valore compreso tra uno e il numero di eventi specificato da questa proprietà.
    Intervallo Numero intero positivo che indica l'intervallo con cui viene eseguito il flusso di lavoro in base alla frequenza
    Frequenza Unità di tempo per la ricorrenza

    Per altre proprietà, aprire l'elenco Aggiungi nuovo parametro. Se si seleziona un parametro, tale proprietà viene aggiunta al trigger, ad esempio:

    Proprietà trigger

    Altre proprietà

    Proprietà Richiesto Descrizione
    Schema contenuto No Schema del contenuto JSON per gli eventi da leggere dall'hub eventi. Ad esempio, se si specifica lo schema del contenuto, è possibile attivare il flusso di lavoro solo per gli eventi che corrispondono allo schema.
    Chiave di partizione minima No Immettere l'ID di partizione minima da leggere. Per impostazione predefinita, vengono lette tutte le partizioni.
    Chiave di partizione massima No Immettere l'ID di partizione massima da leggere. Per impostazione predefinita, vengono lette tutte le partizioni.
    Fuso orario No Valido solo quando si specifica un'ora di inizio, perché il trigger non accetta la differenza dall'ora UTC. Selezionare il fuso orario che si desidera applicare.

    Per altre informazioni, vedere Creare ed eseguire attività e flussi di lavoro ricorrenti con App per la logica di Azure.

    Ora di inizio No Specificare un'ora di inizio nel formato seguente:

    AAAA-MM-GGThh:mm:ss se si seleziona un fuso orario

    oppure

    AAAA-MM-GGThh:mm:ssZ se non si seleziona un fuso orario

    Per altre informazioni, vedere Creare ed eseguire attività e flussi di lavoro ricorrenti con App per la logica di Azure.

  5. Al termine, nella barra degli strumenti di progettazione, seleziona Salva.

  6. Continuare ora ad aggiungere una o più azioni in modo da poter eseguire altre attività usando gli output del trigger.

    Ad esempio, per filtrare gli eventi in base a un valore specifico, ad esempio una categoria, è possibile aggiungere una condizione in modo che l'azione Invia evento invii solo gli eventi che soddisfano la condizione.

Attivare il comportamento di polling

Tutti i trigger di Hub eventi sono trigger di polling lungo. Questo comportamento significa che quando un trigger viene attivato, il trigger elabora tutti gli eventi e attende 30 secondi per visualizzare altri eventi nell'hub eventi. Per impostazione predefinita, se non vengono visualizzati eventi in 30 secondi, il trigger viene ignorato. In caso contrario, il trigger continua a leggere gli eventi finché l'hub eventi non è vuoto. Il polling successivo si baserà sull'intervallo di ricorrenza impostato nelle proprietà del trigger.

Ad esempio, se il trigger è configurato con quattro partizioni, questo ritardo potrebbe richiedere fino a due minuti prima che il trigger termini il polling di tutte le partizioni. Se non vengono ricevuti eventi entro questo ritardo, l'esecuzione del trigger viene ignorata. In caso contrario, il trigger continua a leggere gli eventi finché l'hub eventi non è vuoto. Il polling successivo si baserà sull'intervallo di ricorrenza specificato nelle proprietà del trigger.

Se si conoscono le partizioni specifiche in cui vengono visualizzati i messaggi, è possibile aggiornare il trigger per leggere gli eventi solo da questo o da tali partizioni impostando le chiavi di partizione massime e minime del trigger. Per altre informazioni, vedere la sezione Aggiungi trigger di Hub eventi.

Comportamento del checkpoint del trigger

Quando un trigger di Hub eventi legge gli eventi da ogni partizione in un hub eventi, il trigger usa il proprio stato per mantenere le informazioni sull'offset del flusso (la posizione dell'evento in una partizione) e le partizioni da cui il trigger legge gli eventi.

Ogni volta che viene eseguito il flusso di lavoro, il trigger legge gli eventi da una partizione, a partire dall'offset del flusso mantenuto dallo stato del trigger. In modo round robin, il trigger esegue l'iterazione su ogni partizione nell'hub eventi e legge gli eventi nelle esecuzioni successive del trigger. Una singola esecuzione ottiene eventi da una singola partizione alla volta.

Il trigger non usa questa funzionalità di checkpoint nell'archiviazione, senza costi aggiuntivi. Tuttavia, il punto chiave è che l'aggiornamento del trigger di Hub eventi reimposta lo stato del trigger, che potrebbe causare la lettura degli eventi all'avvio del flusso.

Aggiungere un'azione per Hub eventi

In App per la logica di Azure un'azione segue il trigger o un'altra azione ed esegue alcune operazioni nel flusso di lavoro. I passaggi seguenti descrivono il modo generale per aggiungere un'azione, ad esempio Invia evento. Per questo esempio, il flusso di lavoro inizia con un trigger di Hub eventi che verifica la presenza di nuovi eventi nell'hub eventi.

  1. In Progettazione app per la logica aprire il flusso di lavoro dell'app per la logica, se non è già aperto.

  2. Nel trigger o in un'altra azione aggiungere un nuovo passaggio.

    Per aggiungere un passaggio tra i passaggi esistenti, spostare il mouse sulla freccia. Selezionare il segno più (+) visualizzato e quindi Aggiungi un'azione.

  3. Nella casella di ricerca dell'operazione immettere event hubs. Nell'elenco delle azioni selezionare l'azione denominata Invia evento.

    Selezionare l'azione

  4. Se viene richiesto di creare una connessione all'hub eventi, specificare le informazioni di connessione richieste.

  5. Nell'azione specificare informazioni sugli eventi che si desidera inviare.

    Proprietà Richiesto Descrizione
    Nome hub eventi Hub eventi in cui si vuole inviare l'evento
    Contenuto No Contenuto dell'evento da inviare
    Proprietà No Proprietà dell'app e valori da inviare
    Chiave di partizione No L'ID di partizione per dove inviare l'evento

    Per altre proprietà, aprire l'elenco Aggiungi nuovo parametro. Se si seleziona un parametro, tale proprietà viene aggiunta all'azione, ad esempio:

    Selezionare il nome dell'hub eventi e specificare il contenuto dell'evento

    Ad esempio, è possibile inviare l'output dal trigger di Hub eventi a un altro hub eventi:

    Esempio di evento send

  6. Al termine, nella barra degli strumenti di progettazione, seleziona Salva.

Informazioni di riferimento sui connettori

Per tutte le operazioni e altre informazioni tecniche, ad esempio proprietà, limiti e così via, vedere la pagina di riferimento del connettore di Hub eventi.

Passaggi successivi