Trigger di hub IoT di Azure per Funzioni di Azure

Questo articolo illustra come usare le associazioni Funzioni di Azure per hub IoT. Il supporto hub IoT si basa sull'associazione Hub eventi di Azure.

Per informazioni sui dettagli di impostazione e configurazione, vedere la panoramica.

Importante

Mentre gli esempi di codice seguenti usano l'API hub eventi, la sintassi specificata è applicabile per le funzioni di hub IoT.

Usare il trigger di funzioni per rispondere a un evento inviato a un flusso di eventi di Hub eventi. Per configurare il trigger è necessario avere accesso in lettura all'hub eventi sottostante. Quando la funzione viene attivata, il messaggio passato alla funzione viene tipizzato come stringa.

Le decisioni di ridimensionamento di Hub eventi per i piani a consumo e Premium vengono eseguite tramite scalabilità basata su destinazione. Per altre informazioni, vedere Scalabilità basata su destinazione.

Per informazioni su come Funzioni di Azure risponde agli eventi inviati a un flusso di eventi dell'hub eventi tramite trigger, vedere Integrare Hub eventi con funzioni serverless in Azure.

Importante

Questo articolo usa schede per supportare le versioni diverse del modello di programmazione Node.js. Il modello v4 è disponibile a livello generale ed è progettato per offrire un'esperienza più flessibile e intuitiva per gli sviluppatori JavaScript e TypeScript. Per altre informazioni sul funzionamento del modello v4, vedere la guida per gli sviluppatori di Node.js per Funzioni di Azure. Altre informazioni sulle differenze tra i modelli v3 e v4 sono disponibili nella guida alla migrazione.

Funzioni di Azure supporta due modelli di programmazione per Python. Il modo in cui si definiscono le associazioni dipende dal modello di programmazione scelto.

v2

Il modello di programmazione Python v2 consente di definire associazioni usando elementi Decorator direttamente nel codice della funzione Python. Per altre informazioni, vedere la Guida per sviluppatori Python.

v1

Il modello di programmazione Python v1 richiede di definire associazioni in un file di function.json separato nella cartella della funzione. Per altre informazioni, vedere la Guida per sviluppatori Python.

Questo articolo supporta entrambi i modelli di programmazione.

Esempio

Modello di lavoro isolato

L'esempio seguente mostra una funzione C# attivata in base a un hub eventi, in cui la stringa del messaggio di input viene scritta nei log:

{
    private readonly ILogger<EventHubsFunction> _logger;

    public EventHubsFunction(ILogger<EventHubsFunction> logger)
    {
        _logger = logger;
    }

    [Function(nameof(EventHubFunction))]
    [FixedDelayRetry(5, "00:00:10")]
    [EventHubOutput("dest", Connection = "EventHubConnection")]
    public string EventHubFunction(
        [EventHubTrigger("src", Connection = "EventHubConnection")] string[] input,
        FunctionContext context)
    {
        _logger.LogInformation("First Event Hubs triggered message: {msg}", input[0]);

        var message = $"Output message created at {DateTime.Now}";
        return message;
    }

Modello di processo

Importante

Il supporto terminerà per il modello in-process il 10 novembre 2026. È consigliabile eseguire la migrazione delle app al modello di lavoro isolato per il supporto completo.

L'esempio seguente mostra una funzione C# che registra il corpo del messaggio del trigger di Hub eventi.

[FunctionName("EventHubTriggerCSharp")]
public void Run([EventHubTrigger("samples-workitems", Connection = "EventHubConnectionAppSetting")] string myEventHubMessage, ILogger log)
{
    log.LogInformation($"C# function triggered to process a message: {myEventHubMessage}");
}

Per ottenere l'accesso ai metadati degli eventi nel codice della funzione, eseguire l'associazione a un oggetto EventData. È possibile anche accedere alle stesse proprietà usando le espressioni di associazione nella firma del metodo. Nell'esempio seguente vengono illustrati entrambi i modi per ottenere gli stessi dati:

[FunctionName("EventHubTriggerCSharp")]
public void Run(
    [EventHubTrigger("samples-workitems", Connection = "EventHubConnectionAppSetting")] EventData myEventHubMessage,
    DateTime enqueuedTimeUtc,
    Int64 sequenceNumber,
    string offset,
    ILogger log)
{
    log.LogInformation($"Event: {Encoding.UTF8.GetString(myEventHubMessage.Body)}");
    // Metadata accessed by binding to EventData
    log.LogInformation($"EnqueuedTimeUtc={myEventHubMessage.SystemProperties.EnqueuedTimeUtc}");
    log.LogInformation($"SequenceNumber={myEventHubMessage.SystemProperties.SequenceNumber}");
    log.LogInformation($"Offset={myEventHubMessage.SystemProperties.Offset}");
    // Metadata accessed by using binding expressions in method parameters
    log.LogInformation($"EnqueuedTimeUtc={enqueuedTimeUtc}");
    log.LogInformation($"SequenceNumber={sequenceNumber}");
    log.LogInformation($"Offset={offset}");
}

Per ricevere gli eventi in un batch, impostare string o EventData come matrice.

Nota

Quando vengono ricevuti in un batch non è possibile eseguire l'associazione ai parametri del metodo come nell'esempio precedente con DateTime enqueuedTimeUtc ed è necessario riceverli da ciascun oggetto EventData

[FunctionName("EventHubTriggerCSharp")]
public void Run([EventHubTrigger("samples-workitems", Connection = "EventHubConnectionAppSetting")] EventData[] eventHubMessages, ILogger log)
{
    foreach (var message in eventHubMessages)
    {
        log.LogInformation($"C# function triggered to process a message: {Encoding.UTF8.GetString(message.Body)}");
        log.LogInformation($"EnqueuedTimeUtc={message.SystemProperties.EnqueuedTimeUtc}");
    }
}

Modello v4

L'esempio seguente mostra una funzione TypeScript trigger di Hub eventi. La funzione legge i metadati dell'evento e registra il messaggio.

import { app, InvocationContext } from '@azure/functions';

export async function eventHubTrigger1(message: unknown, context: InvocationContext): Promise<void> {
    context.log('Event hub function processed message:', message);
    context.log('EnqueuedTimeUtc =', context.triggerMetadata.enqueuedTimeUtc);
    context.log('SequenceNumber =', context.triggerMetadata.sequenceNumber);
    context.log('Offset =', context.triggerMetadata.offset);
}

app.eventHub('eventHubTrigger1', {
    connection: 'myEventHubReadConnectionAppSetting',
    eventHubName: 'MyEventHub',
    cardinality: 'one',
    handler: eventHubTrigger1,
});

Per ricevere eventi in un batch, impostare su cardinality many, come illustrato nell'esempio seguente.

import { app, InvocationContext } from '@azure/functions';

export async function eventHubTrigger1(messages: unknown[], context: InvocationContext): Promise<void> {
    context.log(`Event hub function processed ${messages.length} messages`);
    for (let i = 0; i < messages.length; i++) {
        context.log('Event hub message:', messages[i]);
        context.log(`EnqueuedTimeUtc = ${context.triggerMetadata.enqueuedTimeUtcArray[i]}`);
        context.log(`SequenceNumber = ${context.triggerMetadata.sequenceNumberArray[i]}`);
        context.log(`Offset = ${context.triggerMetadata.offsetArray[i]}`);
    }
}

app.eventHub('eventHubTrigger1', {
    connection: 'myEventHubReadConnectionAppSetting',
    eventHubName: 'MyEventHub',
    cardinality: 'many',
    handler: eventHubTrigger1,
});

Modello v3

Gli esempi typeScript non sono documentati per il modello v3.

Modello v4

L'esempio seguente mostra una funzione JavaScript trigger di Hub eventi. La funzione legge i metadati dell'evento e registra il messaggio.

const { app } = require('@azure/functions');

app.eventHub('eventHubTrigger1', {
    connection: 'myEventHubReadConnectionAppSetting',
    eventHubName: 'MyEventHub',
    cardinality: 'one',
    handler: (message, context) => {
        context.log('Event hub function processed message:', message);
        context.log('EnqueuedTimeUtc =', context.triggerMetadata.enqueuedTimeUtc);
        context.log('SequenceNumber =', context.triggerMetadata.sequenceNumber);
        context.log('Offset =', context.triggerMetadata.offset);
    },
});

Per ricevere eventi in un batch, impostare su cardinality many, come illustrato nell'esempio seguente.

const { app } = require('@azure/functions');

app.eventHub('eventHubTrigger1', {
    connection: 'myEventHubReadConnectionAppSetting',
    eventHubName: 'MyEventHub',
    cardinality: 'many',
    handler: (messages, context) => {
        context.log(`Event hub function processed ${messages.length} messages`);
        for (let i = 0; i < messages.length; i++) {
            context.log('Event hub message:', messages[i]);
            context.log(`EnqueuedTimeUtc = ${context.triggerMetadata.enqueuedTimeUtcArray[i]}`);
            context.log(`SequenceNumber = ${context.triggerMetadata.sequenceNumberArray[i]}`);
            context.log(`Offset = ${context.triggerMetadata.offsetArray[i]}`);
        }
    },
});

Modello v3

L'esempio seguente mostra un'associazione di trigger di Hub eventi in un file function.json e una funzione JavaScript che usa l'associazione. La funzione legge i metadati dell'evento e registra il messaggio.

{
  "type": "eventHubTrigger",
  "name": "myEventHubMessage",
  "direction": "in",
  "eventHubName": "MyEventHub",
  "connection": "myEventHubReadConnectionAppSetting"
}

Ecco il codice JavaScript:

module.exports = function (context, myEventHubMessage) {
    context.log('Function triggered to process a message: ', myEventHubMessage);
    context.log('EnqueuedTimeUtc =', context.bindingData.enqueuedTimeUtc);
    context.log('SequenceNumber =', context.bindingData.sequenceNumber);
    context.log('Offset =', context.bindingData.offset);

    context.done();
};

Per ricevere gli eventi in un batch, impostare cardinality su many nel file function.json, come illustrato negli esempi seguenti.

{
  "type": "eventHubTrigger",
  "name": "eventHubMessages",
  "direction": "in",
  "eventHubName": "MyEventHub",
  "cardinality": "many",
  "connection": "myEventHubReadConnectionAppSetting"
}

Ecco il codice JavaScript:

module.exports = function (context, eventHubMessages) {
    context.log(`JavaScript eventhub trigger function called for message array ${eventHubMessages}`);

    eventHubMessages.forEach((message, index) => {
        context.log(`Processed message ${message}`);
        context.log(`EnqueuedTimeUtc = ${context.bindingData.enqueuedTimeUtcArray[index]}`);
        context.log(`SequenceNumber = ${context.bindingData.sequenceNumberArray[index]}`);
        context.log(`Offset = ${context.bindingData.offsetArray[index]}`);
    });

    context.done();
};

Ecco il codice di PowerShell:

param($eventHubMessages, $TriggerMetadata)

Write-Host "PowerShell eventhub trigger function called for message array: $eventHubMessages"

$eventHubMessages | ForEach-Object { Write-Host "Processed message: $_" }

L'esempio seguente mostra un'associazione di trigger di Hub eventi e una funzione Python che usa l'associazione. La funzione legge i metadati dell'evento e registra il messaggio. L'esempio dipende dal fatto che si usi il modello di programmazione Python v1 o v2.

v2

import logging
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="EventHubTrigger1")
@app.event_hub_message_trigger(arg_name="myhub", 
                               event_hub_name="<EVENT_HUB_NAME>",
                               connection="<CONNECTION_SETTING>") 
def test_function(myhub: func.EventHubEvent):
    logging.info('Python EventHub trigger processed an event: %s',
                myhub.get_body().decode('utf-8'))

v1

Gli esempi seguenti illustrano il data binding di Hub eventi nel file function.json.

{
  "type": "eventHubTrigger",
  "name": "event",
  "direction": "in",
  "eventHubName": "MyEventHub",
  "connection": "myEventHubReadConnectionAppSetting"
}

Ecco il codice Python:

import logging
import azure.functions as func


def main(event: func.EventHubEvent):
    logging.info(f'Function triggered to process a message: {event.get_body().decode()}')
    logging.info(f'  EnqueuedTimeUtc = {event.enqueued_time}')
    logging.info(f'  SequenceNumber = {event.sequence_number}')
    logging.info(f'  Offset = {event.offset}')

    # Metadata
    for key in event.metadata:
        logging.info(f'Metadata: {key} = {event.metadata[key]}')

L'esempio seguente mostra un'associazione di trigger di Hub eventi che registra il corpo del messaggio del trigger di Hub eventi.

@FunctionName("ehprocessor")
public void eventHubProcessor(
  @EventHubTrigger(name = "msg",
                  eventHubName = "myeventhubname",
                  connection = "myconnvarname") String message,
       final ExecutionContext context )
       {
          context.getLogger().info(message);
 }

Nella libreria di runtime delle funzioni Java usare l'annotazione EventHubTrigger sui parametri il cui valore proviene dall'hub eventi. I parametri con queste annotazioni attivano l'esecuzione della funzione quando viene ricevuto un evento. Questa annotazione è utilizzabile con i tipi Java nativi, con oggetti POJO o con valori nullable tramite Optional<T>.

Nell'esempio seguente viene illustrato un uso esteso di SystemProperties e altre opzioni di binding per ulteriori introspezioni dell'evento, oltre a fornire un percorso ben formato BlobOutput gerarchico.

package com.example;
import java.util.Map;
import java.time.ZonedDateTime;

import com.microsoft.azure.functions.annotation.*;
import com.microsoft.azure.functions.*;

/**
 * Azure Functions with Event Hub trigger.
 * and Blob Output using date in path along with message partition ID
 * and message sequence number from EventHub Trigger Properties
 */
public class EventHubReceiver {

    @FunctionName("EventHubReceiver")
    @StorageAccount("bloboutput")

    public void run(
            @EventHubTrigger(name = "message",
                eventHubName = "%eventhub%",
                consumerGroup = "%consumergroup%",
                connection = "eventhubconnection",
                cardinality = Cardinality.ONE)
            String message,

            final ExecutionContext context,

            @BindingName("Properties") Map<String, Object> properties,
            @BindingName("SystemProperties") Map<String, Object> systemProperties,
            @BindingName("PartitionContext") Map<String, Object> partitionContext,
            @BindingName("EnqueuedTimeUtc") Object enqueuedTimeUtc,

            @BlobOutput(
                name = "outputItem",
                path = "iotevents/{datetime:yy}/{datetime:MM}/{datetime:dd}/{datetime:HH}/" +
                       "{datetime:mm}/{PartitionContext.PartitionId}/{SystemProperties.SequenceNumber}.json")
            OutputBinding<String> outputItem) {

        var et = ZonedDateTime.parse(enqueuedTimeUtc + "Z"); // needed as the UTC time presented does not have a TZ
                                                             // indicator
        context.getLogger().info("Event hub message received: " + message + ", properties: " + properties);
        context.getLogger().info("Properties: " + properties);
        context.getLogger().info("System Properties: " + systemProperties);
        context.getLogger().info("partitionContext: " + partitionContext);
        context.getLogger().info("EnqueuedTimeUtc: " + et);

        outputItem.setValue(message);
    }
}

Attributi

Sia le librerie C# in-process che il processo di lavoro isolato usano l'attributo per configurare il trigger. Lo script C# usa invece un file di configurazione function.json come descritto nella guida per gli script C#.

Modello di lavoro isolato

EventHubTriggerAttribute Usare per definire un trigger in un hub eventi, che supporta le proprietà seguenti.

Parametri	Descrizione
EventHubName	Nome di Hub eventi. Quando il nome dell'hub eventi è presente anche nella stringa di connessione, tale valore sostituisce questa proprietà in fase di runtime. È possibile fare riferimento alle impostazioni dell'app, ad esempio%eventHubName%
ConsumerGroup	Proprietà facoltativa usata per impostare il gruppo di consumer usato per effettuare la sottoscrizione agli eventi nell'hub. Se omesso, viene utilizzato il $Default gruppo di consumer.
Connessione	Nome di un'impostazione o di una raccolta di impostazioni dell'app che specifica come connettersi a Hub eventi. Per altre informazioni, vedere Connessioni.

Modello di processo

Nelle librerie di classi C# usare EventHubTriggerAttribute, che supporta le proprietà seguenti.

Parametri	Descrizione
EventHubName	Nome di Hub eventi. Quando il nome dell'hub eventi è presente anche nella stringa di connessione, tale valore sostituisce questa proprietà in fase di runtime. È possibile fare riferimento alle impostazioni dell'app, ad esempio%eventHubName%
ConsumerGroup	Proprietà facoltativa usata per impostare il gruppo di consumer usato per effettuare la sottoscrizione agli eventi nell'hub. Se omesso, viene utilizzato il $Default gruppo di consumer.
Connessione	Nome di un'impostazione o di una raccolta di impostazioni dell'app che specifica come connettersi a Hub eventi. Per altre informazioni, vedere Connessioni.

Elementi Decorator

Si applica solo al modello di programmazione Python v2.

Per le funzioni Python v2 definite usando un elemento Decorator, le proprietà seguenti in event_hub_message_trigger:

Proprietà	Descrizione
arg_name	Nome della variabile che rappresenta l'elemento evento nel codice della funzione.
event_hub_name	Nome di Hub eventi. Quando il nome dell'hub eventi è presente anche nella stringa di connessione, tale valore sostituisce questa proprietà in fase di runtime.
connection	Nome di un'impostazione o di una raccolta di impostazioni dell'app che specifica come connettersi a Hub eventi. Vedere Connessioni.

Per le funzioni Python definite tramite function.json, vedere la sezione Configurazione .

Annotazioni

Nella libreria di runtime delle funzioni Java usare l'annotazione EventHubTrigger, che supporta le impostazioni seguenti:

• name
• dataType
• eventHubName
• connection
• cardinality
• consumerGroup

Impostazione

Si applica solo al modello di programmazione Python v1.

Modello v4

Nella tabella seguente vengono illustrate le proprietà che è possibile impostare sull'oggetto options passato al app.eventHub() metodo .

Proprietà	Descrizione
eventHubName	Nome di Hub eventi. Quando il nome dell'hub eventi è presente anche nella stringa di connessione, tale valore sostituisce questa proprietà in fase di runtime. È possibile farvi riferimento tramite le impostazioni dell'app %eventHubName%
consumerGroup	Proprietà facoltativa usata per impostare il gruppo di consumer usato per effettuare la sottoscrizione agli eventi nell'hub. Se omessa, al suo posto viene usato il gruppo di consumer $Default.
cardinality	Impostare su many per abilitare l'invio in batch. Se omessa o impostata su one, alla funzione viene passato un singolo messaggio.
connection	Nome di un'impostazione o di una raccolta di impostazioni dell'app che specifica come connettersi a Hub eventi. Vedere Connessioni.

Modello v3

Nella tabella seguente sono illustrate le proprietà di configurazione dell'associazione impostate nel file function.json.

Proprietà	Descrizione
type	Deve essere impostato su eventHubTrigger. Questa proprietà viene impostata automaticamente quando si crea il trigger nel portale di Azure.
direction	Deve essere impostato su in. Questa proprietà viene impostata automaticamente quando si crea il trigger nel portale di Azure.
name	Nome della variabile che rappresenta l'elemento evento nel codice della funzione.
eventHubName	Nome di Hub eventi. Quando il nome dell'hub eventi è presente anche nella stringa di connessione, tale valore sostituisce questa proprietà in fase di runtime. È possibile farvi riferimento tramite le impostazioni dell'app %eventHubName%
consumerGroup	Proprietà facoltativa usata per impostare il gruppo di consumer usato per effettuare la sottoscrizione agli eventi nell'hub. Se omessa, al suo posto viene usato il gruppo di consumer $Default.
cardinality	Impostare su many per abilitare l'invio in batch. Se omessa o impostata su one, alla funzione viene passato un singolo messaggio.
connection	Nome di un'impostazione o di una raccolta di impostazioni dell'app che specifica come connettersi a Hub eventi. Vedere Connessioni.

La tabella seguente illustra le proprietà di configurazione del trigger impostate nel file function.json, che differisce dalla versione di runtime.

Funzioni 2.x+

Proprietà di function.json	Descrizione
type	Deve essere impostato su eventHubTrigger. Questa proprietà viene impostata automaticamente quando si crea il trigger nel portale di Azure.
direction	Deve essere impostato su in. Questa proprietà viene impostata automaticamente quando si crea il trigger nel portale di Azure.
name	Nome della variabile che rappresenta l'elemento evento nel codice della funzione.
eventHubName	Nome di Hub eventi. Quando il nome dell'hub eventi è presente anche nella stringa di connessione, tale valore sostituisce questa proprietà in fase di runtime. È possibile farvi riferimento tramite le impostazioni dell'app %eventHubName%
consumerGroup	Proprietà facoltativa usata per impostare il gruppo di consumer usato per effettuare la sottoscrizione agli eventi nell'hub. Se omessa, al suo posto viene usato il gruppo di consumer $Default.
cardinality	Impostare su many per abilitare l'invio in batch. Se omessa o impostata su one, alla funzione viene passato un singolo messaggio.
connection	Nome di un'impostazione o di una raccolta di impostazioni dell'app che specifica come connettersi a Hub eventi. Vedere Connessioni.

Funzioni 1.x

Proprietà di function.json	Descrizione
type	Deve essere impostato su eventHubTrigger. Questa proprietà viene impostata automaticamente quando si crea il trigger nel portale di Azure.
direction	Deve essere impostato su in. Questa proprietà viene impostata automaticamente quando si crea il trigger nel portale di Azure.
name	Nome della variabile che rappresenta l'elemento evento nel codice della funzione.
path	Nome di Hub eventi. Quando il nome dell'hub eventi è presente anche nella stringa di connessione, tale valore sostituisce questa proprietà in fase di runtime.
consumerGroup	Proprietà facoltativa usata per impostare il gruppo di consumer usato per effettuare la sottoscrizione agli eventi nell'hub. Se omessa, al suo posto viene usato il gruppo di consumer $Default.
cardinality	Impostare su many per abilitare l'invio in batch. Se omessa o impostata su one, alla funzione viene passato un singolo messaggio.
connection	Nome di un'impostazione o di una raccolta di impostazioni dell'app che specifica come connettersi a Hub eventi. Vedere Connessioni.

Quando si sviluppa in locale, aggiungere le impostazioni dell'applicazione nel file local.settings.json nella Values raccolta.

Utilizzo

Per altre informazioni sul modo in cui Hub eventi attiva e hub IoT la scalabilità dei trigger, vedere Utilizzo di eventi con Funzioni di Azure.

Il tipo di parametro supportato dall'associazione di output di Hub eventi dipende dalla versione del runtime di Funzioni, dalla versione del pacchetto di estensione e dalla modalità C# usata.

Estensione v5.x+

Le funzioni della libreria di classi C# in-process supportano i tipi seguenti:

• Azure.Messaging.EventHubs.EventData
• String
• Matrice di byte
• Oggetto CLR normale (POCO)

Questa versione di EventData elimina il supporto per il tipo legacy Body a favore di EventBody.

Estensione v3.x+

Le funzioni della libreria di classi C# in-process supportano i tipi seguenti:

• Microsoft.Azure.EventHubs.EventData
• String
• Matrice di byte
• Oggetto CLR normale (POCO)

Estensione v5.x+

Quando si vuole che la funzione elabori un singolo evento, il trigger di Hub eventi può essere associato ai tipi seguenti:

Tipo	Descrizione
string	Evento come stringa. Usare quando l'evento è testo semplice.
byte[]	Byte dell'evento.
Tipi serializzabili JSON	Quando un evento contiene dati JSON, Funzioni tenta di deserializzare i dati JSON in un tipo POCO (Plain-Old CLR Object).
Azure.Messaging.EventHubs.EventData1	Oggetto evento. Se si esegue la migrazione da versioni precedenti degli SDK di Hub eventi, si noti che questa versione elimina il supporto per il tipo legacy Body a favore di EventBody.

Quando si vuole che la funzione elabori un batch di eventi, il trigger di Hub eventi può essere associato ai tipi seguenti:

Tipo	Descrizione
string[]	Matrice di eventi del batch, sotto forma di stringhe. Ogni voce rappresenta un evento.
EventData[] 1	Matrice di eventi del batch, come istanze di Azure.Messaging.EventHubs.EventData. Ogni voce rappresenta un evento.
T[] dove T è un tiposerializzabile JSON 1	Matrice di eventi del batch, come istanze di un tipo POCO personalizzato. Ogni voce rappresenta un evento.

¹ Per usare questi tipi, è necessario fare riferimento a Microsoft.Azure.Functions.Worker.Extensions.EventHubs 5.5.0 o versione successiva e alle dipendenze comuni per le associazioni di tipi SDK.

Estensione v3.x+

Richiede di definire un tipo personalizzato o di usare una stringa. Sono disponibili opzioni aggiuntive per l'estensione v5.x+.

Il tipo di parametro può essere uno dei seguenti:

• Qualsiasi tipo Java nativo, ad esempio int, String, byte[].
• Valori nullable usando Facoltativo.
• Qualsiasi tipo POJO.

Per altre informazioni, vedere le informazioni di riferimento su EventHubTrigger .

Metadati di evento

Il trigger di Hub eventi fornisce diverse proprietà di metadati. Le proprietà di metadati possono essere usate come parte delle espressioni di associazione in altre associazioni o come parametri nel codice. Le proprietà derivano dalla classe EventData.

Proprietà	Type	Descrizione
PartitionContext	PartitionContext	Istanza PartitionContext.
EnqueuedTimeUtc	DateTime	Il tempo di accodamento in formato UTC.
Offset	string	Offset dei dati relativi al flusso di partizione dell'hub eventi. L'offset è un indicatore o un identificatore per un evento all'interno del flusso di Hub eventi. L'identificatore è univoco all'interno di una partizione del flusso di Hub eventi.
PartitionKey	string	La partizione a cui devono essere inviati i dati dell'evento.
Properties	IDictionary<String,Object>	Le proprietà dell'utente dei dati dell'evento.
SequenceNumber	Int64	Il numero di sequenza logica dell'evento.
SystemProperties	IDictionary<String,Object>	Le proprietà di sistema, inclusi di dati dell'evento.

Vedere gli esempi di codice che usano queste proprietà in precedenza in questo articolo.

Connessioni

La connection proprietà è un riferimento alla configurazione dell'ambiente che contiene il nome di un'impostazione dell'applicazione contenente un stringa di connessione. È possibile ottenere questo stringa di connessione selezionando il pulsante Informazioni di connessione per lo spazio dei nomi. Il stringa di connessione deve essere per uno spazio dei nomi di Hub eventi, non per l'hub eventi stesso.

Il stringa di connessione deve disporre almeno delle autorizzazioni di lettura per attivare la funzione.

Questo stringa di connessione deve essere archiviato in un'impostazione dell'applicazione con un nome corrispondente al valore specificato dalla connection proprietà della configurazione dell'associazione.

Nota

Le connessioni basate su identità non sono supportate dal trigger di hub IoT. Se è necessario usare identità gestite end-to-end, è invece possibile usare hub IoT Routing per inviare dati a un hub eventi controllato. In questo modo, il routing in uscita può essere autenticato con l'identità gestita che l'evento può essere letto da tale hub eventi usando l'identità gestita.

Proprietà di host.json

Il file host.json contiene le impostazioni che controllano il comportamento del trigger dell'hub eventi. Per informazioni dettagliate sulle impostazioni disponibili, vedere la sezione impostazioni host.json .

Passaggi successivi

• Scrivere eventi in un flusso di eventi (associazione di output)