Connessione a un hub eventi dai flussi di lavoro in App per la logica di Azure
Si applica a: App per la logica di Azure (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 gestiscono 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 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 What is Hub eventi di Azure o What is 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.
Nota
Per le app per la logica ospitate in un ambiente del servizio di integrazione (I edizione Standard), la versione I edizione Standard del connettore usa invece i limiti dei messaggi I edizione Standard.
Prerequisiti
Account e sottoscrizione di Azure. Se non si ha una sottoscrizione di Azure, iscriversi per creare un account Azure gratuito.
Flusso di lavoro dell'app per la logica in cui si vuole accedere all'hub eventi
Per avviare un flusso di lavoro con un trigger di Hub eventi, è necessario un flusso di lavoro vuoto. Se non si ha familiarità con App per la logica di Azure, provare questa guida introduttiva per creare un flusso di lavoro dell'app per la logica a consumo di esempio.
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 il stringa di connessione per lo spazio dei nomi dell'hub eventi.
Nella portale di Azure passare allo spazio dei nomi di Hub eventi, non a un hub eventi specifico.
Nel menu dello spazio dei nomi, in Impostazioni, selezionare Criteri di accesso condiviso. Nella colonna Attestazioni verificare di disporre almeno delle autorizzazioni di gestione per tale spazio dei nomi.
Se si vogliono immettere manualmente le informazioni di connessione, ottenere il stringa di connessione per lo spazio dei nomi dell'hub eventi.
Nella colonna Criteri selezionare RootManageSharedAccessKey.
Trovare la stringa di connessione della chiave primaria. Copiare e salvare il stringa di connessione per un uso successivo.
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 si trova questo parametro, il stringa di connessione è destinato a un'entità "entity" specifica di Hub eventi e non è la stringa corretta da usare con il flusso di lavoro.
Creare una connessione all'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.
Quando richiesto, scegliere una delle opzioni seguenti:
Specificare le informazioni seguenti sulla connessione:
Proprietà Richiesto Valore Descrizione Nome connessione Sì <nome connessione> Nome creato per la connessione Spazio dei nomi di Hub eventi Sì <spazio dei nomi di hub eventi> Selezionare lo spazio dei nomi di Hub eventi da usare. Per immettere manualmente il stringa di connessione salvato in precedenza, selezionare Immettere manualmente le informazioni di connessione. Leggere come trovare la stringa di connessione.
Selezionare i criteri di Hub eventi da usare, se non è già selezionato e quindi selezionare Crea.
Dopo aver creato la connessione, continuare con Aggiungi un trigger di Hub eventi o Aggiungi un'azione 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.
In Progettazione app per la logica aprire il flusso di lavoro dell'app per la logica vuota, se non è già aperto.
Nella casella di ricerca dell'operazione immettere
event hubs. Nell'elenco dei trigger selezionare il trigger denominato When events are available in Event Hub (Quando gli eventi sono disponibili nell'hub eventi).
Se viene richiesto di creare una connessione all'hub eventi, specificare le informazioni di connessione richieste.
Nel trigger fornire informazioni sull'hub eventi che si vuole monitorare, ad esempio:
Proprietà Richiesto Descrizione Nome hub eventi Sì 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 Sì Intero positivo che descrive la frequenza con cui viene eseguito il flusso di lavoro in base alla frequenza Frequenza Sì 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:
Altre proprietà
Proprietà Richiesto Descrizione Schema del 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 in questo formato: AAAA-MM-GGThh:mm:ss se si seleziona un fuso orario
-o-
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.
Al termine, nella barra degli strumenti di progettazione, seleziona Salva.
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 fino a quando l'hub eventi non è vuoto. Il polling del trigger successivo viene eseguito in base all'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 fino a quando 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 Add Event Hubs trigger (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 utenti 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.
In Progettazione app per la logica aprire il flusso di lavoro dell'app per la logica, se non è già aperto.
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.
Nella casella di ricerca dell'operazione immettere
event hubs. Nell'elenco delle azioni selezionare l'azione denominata Invia evento.
Se viene richiesto di creare una connessione all'hub eventi, specificare le informazioni di connessione richieste.
Nell'azione specificare informazioni sugli eventi che si desidera inviare.
Proprietà Richiesto Descrizione Nome hub eventi Sì 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 ID 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:
Ad esempio, è possibile inviare l'output dal trigger di Hub eventi a un altro hub eventi:
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.
Nota
Per le app per la logica ospitate in un ambiente del servizio di integrazione (I edizione Standard), la versione I edizione Standard del connettore usa invece i limiti dei messaggi I edizione Standard.