Azure İşlevleri için Azure Event Hubs çıkış bağlaması

Python v2 programlama modeli, doğrudan Python işlev kodunuzda dekoratörleri kullanarak bağlamaları tanımlamanıza olanak tanır. Daha fazla bilgi için bkz . Python geliştirici kılavuzu.

Python v1 programlama modeli, işlev klasöründeki ayrı bir function.json dosyasında bağlamaları tanımlamanızı gerektirir. Daha fazla bilgi için bkz . Python geliştirici kılavuzu.

Aşağıdaki örnekte, yöntem dönüş değerini çıkış olarak kullanarak bir olay hub'ına ileti dizesi yazan bir C# işlevi gösterilmektedir:

[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;
}

Aşağıdaki örnekte, yöntem dönüş değerini çıkış olarak kullanarak bir olay hub'ına ileti yazan bir C# işlevi gösterilmektedir:

[FunctionName("EventHubOutput")]
[return: EventHub("outputEventHubMessage", Connection = "EventHubConnectionAppSetting")]
public static string Run([TimerTrigger("0 */5 * * * *")] TimerInfo myTimer, ILogger log)
{
    log.LogInformation($"C# Timer trigger function executed at: {DateTime.Now}");
    return $"{DateTime.Now}";
}

Aşağıdaki örnekte, toplu ileti göndermek için arabirimin IAsyncCollector nasıl kullanılacağı gösterilmektedir. Bu senaryo, bir olay hub'ından gelen iletileri işlerken ve sonucu başka bir olay hub'ına gönderirken yaygındır.

[FunctionName("EH2EH")]
public static async Task Run(
    [EventHubTrigger("source", Connection = "EventHubConnectionAppSetting")] EventData[] events,
    [EventHub("dest", Connection = "EventHubConnectionAppSetting")]IAsyncCollector<EventData> outputEvents,
    ILogger log)
{
    foreach (EventData eventData in events)
    {
        // Do some processing:
        string newEventBody = DoSomething(eventData);

        // Queue the message to be sent in the background by adding it to the collector.
        // If only the event is passed, an Event Hubs partition to be assigned via
        // round-robin for each batch.
        await outputEvents.AddAsync(new EventData(newEventBody));

        // If your scenario requires that certain events are grouped together in an
        // Event Hubs partition, you can specify a partition key.  Events added with 
        // the same key will always be assigned to the same partition.        
        await outputEvents.AddAsync(new EventData(newEventBody), "sample-key");
    }
}

Aşağıdaki örnekte, bir olay hub'ına tek bir ileti gönderen zamanlayıcı ile tetiklenen TypeScript işlevi gösterilmektedir:

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

export async function timerTrigger1(myTimer: Timer, context: InvocationContext): Promise<string> {
    const timeStamp = new Date().toISOString();
    return `Message created at: ${timeStamp}`;
}

app.timer('timerTrigger1', {
    schedule: '0 */5 * * * *',
    return: output.eventHub({
        eventHubName: 'myeventhub',
        connection: 'MyEventHubSendAppSetting',
    }),
    handler: timerTrigger1,
});

Birden çok iletinin çıktısını almak için tek bir nesne yerine bir dizi döndürebilirsiniz. Örneğin:

const timeStamp = new Date().toISOString();
const message = `Message created at: ${timeStamp}`;
return [`1: ${message}`, `2: ${message}`];

Model v3 için TypeScript örnekleri belgelenmez.

Aşağıdaki örnekte, bir olay hub'ına tek bir ileti gönderen süreölçer tarafından tetiklenen JavaScript işlevi gösterilmektedir :

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

const eventHubOutput = output.eventHub({
    eventHubName: 'myeventhub',
    connection: 'MyEventHubSendAppSetting',
});

app.timer('timerTrigger1', {
    schedule: '0 */5 * * * *',
    return: eventHubOutput,
    handler: (myTimer, context) => {
        const timeStamp = new Date().toISOString();
        return `Message created at: ${timeStamp}`;
    },
});

Birden çok iletinin çıktısını almak için tek bir nesne yerine bir dizi döndürebilirsiniz. Örneğin:

const timeStamp = new Date().toISOString();
const message = `Message created at: ${timeStamp}`;
return [`1: ${message}`, `2: ${message}`];

Aşağıdaki örnekte, bir function.json dosyasında olay hub'ı tetikleyici bağlaması ve bağlamayı kullanan bir işlev gösterilmektedir. işlevi bir olay hub'ına bir çıkış iletisi yazar.

Aşağıdaki örnekte, function.json dosyasındaki event hubs bağlama verileri gösterilmektedir ve bu veriler İşlevler çalışma zamanının 1.x sürümü için daha sonraki sürümlerle karşılaştırıldığında farklıdır.

{
    "type": "eventHub",
    "name": "outputEventHubMessage",
    "eventHubName": "myeventhub",
    "connection": "MyEventHubSendAppSetting",
    "direction": "out"
}

Tek bir ileti gönderen JavaScript kodu aşağıdadır:

module.exports = function (context, myTimer) {
    var timeStamp = new Date().toISOString();
    context.log('Message created at: ', timeStamp);   
    context.bindings.outputEventHubMessage = "Message created at: " + timeStamp;
    context.done();
};

Birden çok ileti gönderen JavaScript kodu aşağıdadır:

module.exports = function(context) {
    var timeStamp = new Date().toISOString();
    var message = 'Message created at: ' + timeStamp;

    context.bindings.outputEventHubMessage = [];

    context.bindings.outputEventHubMessage.push("1 " + message);
    context.bindings.outputEventHubMessage.push("2 " + message);
    context.done();
};

import logging
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="eventhub_output")
@app.route(route="eventhub_output")
@app.event_hub_output(arg_name="event",
                      event_hub_name="<EVENT_HUB_NAME>",
                      connection="<CONNECTION_SETTING>")
def eventhub_output(req: func.HttpRequest, event: func.Out[str]):
    body = req.get_body()
    if body is not None:
        event.set(body.decode('utf-8'))
    else:    
        logging.info('req body is none')
    return 'ok'

Birden çok ileti gönderen Python kodu aşağıdadır:

import logging
import azure.functions as func
from typing import List

app = func.FunctionApp()

@app.function_name(name="eventhub_output")
@app.route(route="eventhub_output")
@app.event_hub_output(arg_name="event",
                      event_hub_name="<EVENT_HUB_NAME>",
                      connection="<CONNECTION_SETTING>")

def eventhub_output(req: func.HttpRequest, event: func.Out[List[str]]) -> func.HttpResponse:
    my_messages=["message1", "message2","message3"]
    event.set(my_messages)
    return func.HttpResponse(f"Messages sent")

Aşağıdaki örneklerde function.json dosyasında event hubs bağlama verileri gösterilmektedir.

{
    "type": "eventHub",
    "name": "$return",
    "eventHubName": "myeventhub",
    "connection": "MyEventHubSendAppSetting",
    "direction": "out"
}

Tek bir ileti gönderen Python kodu aşağıdadır:

import datetime
import logging
import azure.functions as func


def main(timer: func.TimerRequest) -> str:
    timestamp = datetime.datetime.utcnow()
    logging.info('Message created at: %s', timestamp)
    return 'Message created at: {}'.format(timestamp)

Birden çok ileti gönderen Python kodu aşağıdadır:

import logging
from typing import List
import azure.functions as func


def main(req: func.HttpRequest, messages:func.Out[List[str]]) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')
    messages.set([{"message1"}, {"message2"}])
    return func.HttpResponse(f"Messages sent")

Aşağıdaki özellikleri destekleyen bir olay hub'ına çıkış bağlaması tanımlamak için [EventHubOutputAttribute] kullanın.

Aşağıdaki özellikleri destekleyen bir olay hub'ına çıkış bağlaması tanımlamak için EventHubAttribute kullanın.

Aşağıdaki tabloda, yöntemine geçirilen output.eventHub() nesnede options ayarlayabileceğiniz özellikler açıklanmaktadır.

Aşağıdaki tabloda, function.json dosyasında ayarladığınız bağlama yapılandırma özellikleri açıklanmaktadır.

İşlem içi C# sınıf kitaplığı işlevleri aşağıdaki türleri destekler:

• Azure.Messaging.EventHubs.EventData
• String
• Bayt dizisi
• Düz eski CLR nesnesi (POCO)

EventData'nın bu sürümü, EventBody yerine eski Body tür için desteği bırakır.

gibi out string paramNamebir yöntem parametresi kullanarak ileti gönderme. Birden çok ileti yazmak için veya yerine kullanabilirsiniz ICollector<EventData> IAsyncCollector<EventData>.out string Bölüm anahtarları yalnızca ile IAsyncCollector<EventData>kullanılabilir.

İşlem içi C# sınıf kitaplığı işlevleri aşağıdaki türleri destekler:

• Microsoft.Azure.EventHubs.EventData
• String
• Bayt dizisi
• Düz eski CLR nesnesi (POCO)

gibi out string paramNamebir yöntem parametresi kullanarak ileti gönderme. Birden çok ileti yazmak için veya yerine kullanabilirsiniz ICollector<string> IAsyncCollector<string>.out string

İşlevin tek bir olay yazmasını istediğinizde Event Hubs çıkış bağlaması aşağıdaki türlere bağlanabilir:

İşlevin birden çok olay yazmasını istediğinizde Event Hubs çıkış bağlaması aşağıdaki türlere bağlanabilir:

Diğer çıkış senaryoları için doğrudan Azure.Messaging.EventHubs'daki diğer türlerle bir EventHubProducerClient oluşturun ve kullanın. Azure SDK'dan bir istemci türü oluşturmak için bağımlılık ekleme kullanma örneği için bkz . Azure istemcilerini kaydetme.

Özel bir tür tanımlamanızı veya dize kullanmanızı gerektirir. Uzantı v5.x+ ile ek seçenekler sağlanır.

Değeri doğrudan döndürerek veya kullanarak context.extraOutputs.set()çıkış iletisine erişin.

function.json özelliğinde belirtilen değeri kullanarak context.bindings.<name> <name> çıkış olayına name erişin.