Azure İşlevleri için Azure Event Hubs tetikleyicisi

Bu makalede, Azure İşlevleri için Azure Event Hubs tetikleyicisi ile çalışma açıklanır. Azure İşlevleri, Event Hubs için tetikleyici ve output bağlamalarını destekler.

Kurulum ve yapılandırma ayrıntıları hakkında bilgi için genel bakışa bakın.

Olay hub'ı olay akışına gönderilen bir olayı yanıtlamak için işlev tetikleyicisini kullanın. Tetikleyiciyi ayarlamak için temel olay hub'ına okuma erişiminiz olmalıdır. İşlev tetiklendiğinde, işleve geçirilen ileti dize olarak yazılır.

Tüketim ve Premium planları için Event Hubs ölçeklendirme kararları Hedef Tabanlı Ölçeklendirme aracılığıyla yapılır. Daha fazla bilgi için bkz . Hedef Tabanlı Ölçeklendirme.

Azure İşlevleri tetikleyicileri kullanarak olay hub'ına gönderilen olaylara nasıl yanıt verdiği hakkında bilgi için bkz. Azure üzerinde sunucusuz işlevlerle Event Hubs'ı ayırma.

Önemli

Bu makalede, Node.js programlama modelinin birden çok sürümünü desteklemek için sekmeler kullanılır. Genel kullanıma sunulan v4 modeli, JavaScript ve TypeScript geliştiricileri için daha esnek ve sezgisel bir deneyime sahip olacak şekilde tasarlanmıştır. v4 modelinin nasıl çalıştığı hakkında daha fazla bilgi için Azure İşlevleri Node.js geliştirici kılavuzuna bakın. v3 ile v4 arasındaki farklar hakkında daha fazla bilgi edinmek için geçiş kılavuzuna bakın.

Azure İşlevleri, Python için iki programlama modelini destekler. Bağlamalarınızı tanımlama şekliniz seçtiğiniz programlama modeline bağlıdır.

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

Bu makale her iki programlama modelini de destekler.

Aşağıdaki örnekte, giriş iletisi dizesinin günlüklere yazıldığı bir olay hub'ı temelinde tetiklenen bir C# işlevi gösterilmektedir:

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

Önemli

İşlem içi model desteği 10 Kasım 2026'da sona erecektir. Tam destek için uygulamalarınızı yalıtılmış çalışan modeline geçirmenizi kesinlikle öneririz.

Aşağıdaki örnekte Event Hubs tetikleyicisinin ileti gövdesini günlüğe kaydeden bir C# işlevi gösterilmektedir.

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

İşlev kodunda olay meta verilerine erişmek için bir EventData nesnesine bağlayın. Yöntem imzasında bağlama ifadelerini kullanarak da aynı özelliklere erişebilirsiniz. Aşağıdaki örnekte aynı verileri almanın her iki yolu da gösterilmektedir:

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

Olayları toplu olarak almak için veya stringEventData dizi yapın.

Not

Bir toplu işlemde alırken, ile yukarıdaki örnekteki DateTime enqueuedTimeUtc gibi yöntem parametrelerine bağlanamazsınız ve bunları her EventData nesneden almanız gerekir

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

Model v4
Model v3

Aşağıdaki örnekte Event Hubs tetikleyici TypeScript işlevi gösterilmektedir. İşlev olay meta verilerini okur ve iletiyi günlüğe kaydeder.

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,
});

Olayları toplu olarak almak için, aşağıdaki örnekte gösterildiği gibi olarak ayarlayın cardinalitymany.

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,
});

Model v4
Model v3

Aşağıdaki örnekte Event Hubs tetikleyicisi JavaScript işlevi gösterilmektedir. İşlev olay meta verilerini okur ve iletiyi günlüğe kaydeder.

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);
    },
});

Olayları toplu olarak almak için, aşağıdaki örnekte gösterildiği gibi olarak ayarlayın cardinalitymany.

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]}`);
        }
    },
});

Aşağıdaki örnekte, bir function.json dosyasında Event Hubs tetikleyici bağlaması ve bağlamayı kullanan bir JavaScript işlevi gösterilmektedir. İşlev olay meta verilerini okur ve iletiyi günlüğe kaydeder.

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

JavaScript kodu şu şekildedir:

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();
};

Olayları toplu olarak almak için, aşağıdaki örneklerde cardinality dosyasında olarak ayarlayın many.

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

JavaScript kodu şu şekildedir:

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();
};

PowerShell kodu şu şekildedir:

param($eventHubMessages, $TriggerMetadata)

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

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

Bu örnek, Event Hubs tetikleyicisi tarafından sağlanan temel alınan EventData nesneye doğrudan erişmek için SDK türlerini kullanır:

işlevi olay gövdesini okur ve günlüğe kaydeder.

import logging
import azure.functions as func
import azurefunctions.extensions.bindings.eventhub as eh

app = func.FunctionApp(http_auth_level=func.AuthLevel.FUNCTION)

@app.event_hub_message_trigger(
    arg_name="event", event_hub_name="EVENTHUB_NAME", connection="EventHubConnection"
)
def eventhub_trigger(event: eh.EventData):
    logging.info(
        "Python EventHub trigger processed an event %s",
        event.body_as_str()
    )

EventData türünü kullanma örnekleri için bkz. EventData örnekleri. İşlev uygulamanıza SDK türü bağlamaları ekleme hakkında adım adım öğretici için Event Hubs Örneği için Python SDK Bağlamaları'nı izleyin.

Not

Bilinen sınırlamalar şunlardır:

enqueued_time özelliği desteklenmiyor.
Batch ileti desteği, çalışma zamanı sürüm 4.1039 veya üzeri ile desteklenir.

Desteklenen diğer SDK türü bağlamaları da dahil olmak üzere daha fazla bilgi edinmek için bkz. SDK türü bağlamaları.

Aşağıdaki örnekte Event Hubs tetikleyici bağlaması ve bağlamayı kullanan bir Python işlevi gösterilmektedir. İşlev olay meta verilerini okur ve iletiyi günlüğe kaydeder. Örnek, v1 veya v2 Python programlama modelini mi kullandığınıza bağlıdır.

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'))

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

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

Python kodu şu şekildedir:

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]}')

Aşağıdaki örnekte Event Hubs tetikleyicisinin ileti gövdesini günlüğe kaydeden bir Event Hubs tetikleyici bağlaması gösterilmektedir.

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

Java işlevleri çalışma zamanı kitaplığında değeri olay hub'ından gelen parametrelerde EventHubTrigger ek açıklamasını kullanın. Bu ek açıklamalara sahip parametreler, bir olay geldiğinde işlevin çalışmasına neden olur. Bu ek açıklama Optional<T> kullanılarak yerel Java türleri, POJO'lar veya null atanabilir değerlerle kullanılabilir.

Aşağıdaki örnek, Olay'ın SystemProperties daha fazla iç içe dönük olarak kullanılması ve diğer Bağlama seçeneklerinin kapsamlı kullanımını ve Tarih hiyerarşisi olan iyi biçimlendirilmiş BlobOutput bir yol sağlamayı göstermektedir.

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

Özellikler

Hem işlem içi hem de yalıtılmış çalışan işlemi C# kitaplıkları tetikleyiciyi yapılandırmak için özniteliğini kullanır. Bunun yerine C# betiği, C# betik kılavuzunda açıklandığı gibi bir function.json yapılandırma dosyası kullanır.

Yalıtılmış çalışan modeli
İşlem içi model

Aşağıdaki özellikleri destekleyen bir olay hub'ına tetikleyici tanımlamak için öğesini EventHubTriggerAttribute kullanın.

Parametreler	Açıklama
EventHubName	Olay hub'ının adı. olay hub'ı adı da bağlantı dizesi mevcut olduğunda, bu değer çalışma zamanında bu özelliği geçersiz kılar. Aşağıdakiler gibi uygulama ayarlarından başvurulabilir:`%eventHubName%`
ConsumerGroup	Hub'daki olaylara abone olmak için kullanılan tüketici grubunu ayarlayan isteğe bağlı bir özellik. Atlandığında, `$Default` tüketici grubu kullanılır.
Bağlantı	Event Hubs'a nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Daha fazla bilgi için bkz . Bağlantılar.

C# sınıf kitaplıklarında, aşağıdaki özellikleri destekleyen EventHubTriggerAttribute'u kullanın.

Parametreler	Açıklama
EventHubName	Olay hub'ının adı. olay hub'ı adı da bağlantı dizesi mevcut olduğunda, bu değer çalışma zamanında bu özelliği geçersiz kılar. Aşağıdakiler gibi uygulama ayarlarından başvurulabilir:`%eventHubName%`
ConsumerGroup	Hub'daki olaylara abone olmak için kullanılan tüketici grubunu ayarlayan isteğe bağlı bir özellik. Atlandığında, `$Default` tüketici grubu kullanılır.
Bağlantı	Event Hubs'a nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Daha fazla bilgi için bkz . Bağlantılar.

Dekoratörler

Uygulamalar yalnızca Python v2 programlama modeli.

Dekoratör kullanılarak tanımlanan Python v2 işlevleri için, event_hub_message_trigger üzerinde aşağıdaki özellikler:

Özellik	Açıklama
`arg_name`	İşlev kodundaki olay öğesini temsil eden değişkenin adı.
`event_hub_name`	Olay hub'ının adı. olay hub'ı adı da bağlantı dizesi mevcut olduğunda, bu değer çalışma zamanında bu özelliği geçersiz kılar.
`connection`	Event Hubs'a nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

function.json kullanılarak tanımlanan Python işlevleri için Configuration bölümüne bakın.

Ek Açıklamalar

Java işlevleri çalışma zamanı kitaplığında aşağıdaki ayarları destekleyen EventHubTrigger ek açıklamasını kullanın:

Yapılandırma

Uygulamalar yalnızca Python v1 programlama modeli.

Model v4
Model v3

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

Özellik	Açıklama
eventHubName	Olay hub'ının adı. olay hub'ı adı da bağlantı dizesi mevcut olduğunda, bu değer çalışma zamanında bu özelliği geçersiz kılar. Uygulama ayarları aracılığıyla başvurulabilir `%eventHubName%`
consumerGroup	Hub'daki olaylara abone olmak için kullanılan tüketici grubunu ayarlayan isteğe bağlı bir özellik. Atlanırsa, `$Default` tüketici grubu kullanılır.
Önem düzeyi	`many` Toplu işlemi etkinleştirmek için olarak ayarlayın. atlanırsa veya olarak `one`ayarlanırsa işleve tek bir ileti geçirilir.
bağlantı	Event Hubs'a nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

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

Özellik	Açıklama
türü	olarak ayarlanmalıdır `eventHubTrigger`. Bu özellik, tetikleyiciyi Azure portalında oluşturduğunuzda otomatik olarak ayarlanır.
yön	olarak ayarlanmalıdır `in`. Bu özellik, tetikleyiciyi Azure portalında oluşturduğunuzda otomatik olarak ayarlanır.
ad	İşlev kodundaki olay öğesini temsil eden değişkenin adı.
eventHubName	Olay hub'ının adı. olay hub'ı adı da bağlantı dizesi mevcut olduğunda, bu değer çalışma zamanında bu özelliği geçersiz kılar. Uygulama ayarları aracılığıyla başvurulabilir `%eventHubName%`
consumerGroup	Hub'daki olaylara abone olmak için kullanılan tüketici grubunu ayarlayan isteğe bağlı bir özellik. Atlanırsa, `$Default` tüketici grubu kullanılır.
Önem düzeyi	`many` Toplu işlemi etkinleştirmek için olarak ayarlayın. atlanırsa veya olarak `one`ayarlanırsa işleve tek bir ileti geçirilir.
bağlantı	Event Hubs'a nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

Aşağıdaki tabloda, çalışma zamanı sürümüne göre farklılık gösteren function.json dosyasında ayarladığınız tetikleyici yapılandırma özellikleri açıklanmaktadır.

İşlevler 2.x+
İşlevler 1.x

function.json özelliği	Açıklama
türü	olarak ayarlanmalıdır `eventHubTrigger`. Bu özellik, tetikleyiciyi Azure portalında oluşturduğunuzda otomatik olarak ayarlanır.
yön	olarak ayarlanmalıdır `in`. Bu özellik, tetikleyiciyi Azure portalında oluşturduğunuzda otomatik olarak ayarlanır.
ad	İşlev kodundaki olay öğesini temsil eden değişkenin adı.
eventHubName	Olay hub'ının adı. olay hub'ı adı da bağlantı dizesi mevcut olduğunda, bu değer çalışma zamanında bu özelliği geçersiz kılar. Uygulama ayarları aracılığıyla başvurulabilir `%eventHubName%`
consumerGroup	Hub'daki olaylara abone olmak için kullanılan tüketici grubunu ayarlayan isteğe bağlı bir özellik. Atlanırsa, `$Default` tüketici grubu kullanılır.
Önem düzeyi	`many` Toplu işlemi etkinleştirmek için olarak ayarlayın. atlanırsa veya olarak `one`ayarlanırsa işleve tek bir ileti geçirilir.
bağlantı	Event Hubs'a nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.
Datatype	Tetikleyici girişinin türünü ayarlayan isteğe bağlı bir özellik. Girişin geçerli JSON olup olmadığını seçin `stringbinary` .

function.json özelliği	Açıklama
türü	olarak ayarlanmalıdır `eventHubTrigger`. Bu özellik, tetikleyiciyi Azure portalında oluşturduğunuzda otomatik olarak ayarlanır.
yön	olarak ayarlanmalıdır `in`. Bu özellik, tetikleyiciyi Azure portalında oluşturduğunuzda otomatik olarak ayarlanır.
ad	İşlev kodundaki olay öğesini temsil eden değişkenin adı.
yol	Olay hub'ının adı. olay hub'ı adı da bağlantı dizesi mevcut olduğunda, bu değer çalışma zamanında bu özelliği geçersiz kılar.
consumerGroup	Hub'daki olaylara abone olmak için kullanılan tüketici grubunu ayarlayan isteğe bağlı bir özellik. Atlanırsa, `$Default` tüketici grubu kullanılır.
Önem düzeyi	`many` Toplu işlemi etkinleştirmek için olarak ayarlayın. atlanırsa veya olarak `one`ayarlanırsa işleve tek bir ileti geçirilir.
bağlantı	Event Hubs'a nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

Yerel olarak geliştirme yaparken uygulama ayarlarınızı koleksiyondaki local.settings.json dosyasınaValues ekleyin.

Kullanım

Event Hubs'ın nasıl tetiklenmesi ve IoT Hub tetikleyici ölçekleri hakkında daha fazla bilgi edinmek için bkz. Azure İşlevleri ile Consuming Events.

İşlevler, Azure Event Hubs için Python SDK türü bağlamalarını da destekler ve bu da aşağıdaki temel SDK türlerini kullanarak verilerle çalışmanızı sağlar:

EventData

Önemli

Python'da Event Hubs SDK türleri desteği Önizleme aşamasındadır ve yalnızca Python v2 programlama modeli için desteklenir. Daha fazla bilgi için bkz. Python SDK türleri.

Event Hubs çıkış bağlaması tarafından desteklenen parametre türü İşlevler çalışma zamanı sürümüne, uzantı paketi sürümüne ve kullanılan C# modalitesine bağlıdır.

İşlevin tek bir olayı işlemesini istediğinizde Event Hubs tetikleyicisi aşağıdaki türlere bağlanabilir:

Türü	Açıklama
`string`	Dize olarak olay. Olay basit bir metin olduğunda kullanın.
`byte[]`	Olayın baytları.
JSON serileştirilebilir türler	Bir olay JSON verileri içerdiğinde İşlevler, JSON verilerinin seri durumdan çıkarılarak düz eski bir CLR nesnesi (POCO) türüne dönüştürülmeye çalışılır.
Azure. Messaging.EventHubs.EventData¹	Olay nesnesi. Event Hubs SDK'larının herhangi bir eski sürümünden geçiş gerçekleştiriyorsanız, bu sürümün EventBody yerine eski `Body` tür için desteği bıraktığına dikkat edin.

İşlevin bir grup olayı işlemesini istediğinizde Event Hubs tetikleyicisi aşağıdaki türlere bağlanabilir:

Türü	Açıklama
`string[]`	Toplu işlemden dizeler olarak bir dizi olay. Her girdi bir olayı temsil eder.
`EventData[]` ¹	Azure örneği olarak toplu işlemden olay dizisi. Messaging.EventHubs.EventData. Her girdi bir olayı temsil eder.
`T[]` burada `T` JSON seri hale getirilebilir tür^1'dir	Özel POCO türünün örnekleri olarak toplu işlemden olay dizisi. Her girdi bir olayı temsil eder.

1 Bu türleri kullanmak için Microsoft.Azure başvurmanız gerekir. Functions.Worker.Extensions.EventHubs 5.5.0 veya üzeri ve SDK türü bağlamaları için koşu bağımlılıkları.

Parametre türü aşağıdakilerden biri olabilir:

int, String, byte[] gibi yerel Java türleri.
İsteğe Bağlı'nın kullanıldığı null atanabilir değerler.
Herhangi bir POJO türü.

Daha fazla bilgi edinmek için bkz . EventHubTrigger başvurusu.

Olay meta verileri

Event Hubs tetikleyicisi çeşitli meta veri özellikleri sağlar. Meta veri özellikleri, diğer bağlamalardaki bağlama ifadelerinin bir parçası olarak veya kodunuzdaki parametreler olarak kullanılabilir. Özellikler EventData sınıfından gelir.

Özellik	Türü	Açıklama
`PartitionContext`	PartitionContext	`PartitionContext` örneği.
`EnqueuedTimeUtc`	`DateTime`	UTC olarak sıralanan saat.
`Offset`	`string`	Verilerin olay hub'ı bölüm akışına göre uzaklığı. Uzaklık, Event Hubs akışındaki bir olayın işaretçisi veya tanımlayıcısıdır. Tanımlayıcı, Event Hubs akışının bir bölümünde benzersizdir.
`PartitionKey`	`string`	Olay verilerinin gönderilmesi gereken bölüm.
`Properties`	`IDictionary<String,Object>`	Olay verilerinin kullanıcı özellikleri.
`SequenceNumber`	`Int64`	Olayın mantıksal sıra numarası.
`SystemProperties`	`IDictionary<String,Object>`	Olay verileri dahil olmak üzere sistem özellikleri.

Bu makalenin önceki bölümlerinde bu özellikleri kullanan kod örneklerine bakın.

Bağlantılar

connection özelliği, uygulamanın Event Hubs'a nasıl bağlanması gerektiğini belirten bir ortam yapılandırması başvurusudur. Şunları belirtebilir:

bağlantı dizesi içeren bir uygulama ayarının adı.
Birden çok uygulama ayarı için paylaşılan ön ekin adı ve birlikte yönetilen kimlik bağlantısı tanımlama.

Yapılandırılan değer hem tek bir ayar için tam eşleşme hem de diğer ayarlar için bir ön ek eşleşmesiyse, tam eşleşme kullanılır.

Tavsiye

Gelişmiş güvenlik için bağlantı dizeleri üzerinden yönetilen kimlik bağlantıları önerilir. Bağlantı dizeleri kullanıma sunulan kimlik bilgilerini içerirken yönetilen kimlikler gizli dizileri yönetme gereksinimini ortadan kaldırır.

Yönetilen kimlik
Bağlantı dizesi

Uzantının version 5.x veya üzerini kullanıyorsanız gizli diziyle bağlantı dizesi kullanmak yerine uygulamanın Microsoft Entra kimliği kullanmasını sağlayabilirsiniz. Bunu yapmak için, tetikleyici ve bağlama yapılandırmasındaki özelliğiyle connection eşlenen ortak bir ön ekin altında ayarlar tanımlayabilirsiniz.

Bu modda, uzantı aşağıdaki uygulama ayarlarını gerektirir:

Şablon tabanlı ayar	Açıklama	Kimlik türü
`<CONNECTION_NAME_PREFIX>__fullyQualifiedNamespace`	Tam Event Hubs ad alanı.	Sistem tarafından atanan veya kullanıcı tarafından atanan
`<CONNECTION_NAME_PREFIX>__credential`	olarak ayarlanmalıdır `managedidentity`.	Kullanıcı tarafından atanan
`<CONNECTION_NAME_PREFIX>__clientId`	Kullanıcıya atanmış yönetilen kimliğin istemci ID'si.	Kullanıcı tarafından atanan

ile değiştirdiğiniz <CONNECTION_NAME_PREFIX> değer, bağlama uzantısı tarafından bağlantı ayarının adı olarak değerlendirilir.

Örneğin, bağlama yapılandırmanız kullanıcı tarafından atanan yönetilen kimlikle belirtiliyorsa connection = "EventHubConnection" aşağıdaki uygulama ayarlarını yapılandırabilirsiniz:

{
    "EventHubConnection__fullyQualifiedNamespace": "myeventhubns.servicebus.windows.net",
    "EventHubConnection__credential": "managedidentity",
    "EventHubConnection__clientId": "00000000-0000-0000-0000-000000000000"
}

Tavsiye

Birden çok kaynakta kimlik izinleri üzerinde ayrıntılı denetime ihtiyacınız olan üretim senaryoları için kullanıcı tarafından atanan yönetilen kimlikleri kullanın.

Bağlantıyı daha fazla özelleştirmek için şablondaki ek ayarları kullanabilirsiniz. Bkz. Kimlik tabanlı bağlantılar için ortak özellikler.

Not

Yönetilen Kimlik bağlantılarının ayarlarını sağlamak için Azure Uygulama Yapılandırması veya Key Vault kullanırken, adların doğru çözümlendiğinden emin olmak için adların doğru çözümlendiğinden emin olmak için : yerine / veya __ gibi geçerli bir anahtar ayırıcısı kullanılmalıdır.

Örneğin: EventHubConnection:fullyQualifiedNamespace

Azure İşlevleri hizmetinde barındırıldığında, kimlik tabanlı bağlantılar managed identity kullanır. Ve özellikleriyle credentialclientID kullanıcı tarafından atanan bir kimlik belirtilse de, sistem tarafından atanan kimlik varsayılan olarak kullanılır. Kullanıcı tarafından atanan kimliği kaynak kimliğiyle yapılandırmanın desteklenmediğini unutmayın. Yerel geliştirme gibi diğer bağlamlarda çalıştırıldığında, bunun yerine geliştirici kimliğiniz kullanılır, ancak bu özelleştirilebilir. Bkz. Kimlik tabanlı bağlantılarla yerel geliştirme.

Kimliğe izin verme

Hangi kimlik kullanılıyorsa, hedeflenen eylemleri gerçekleştirmek için izinlere sahip olmalıdır. Çoğu Azure hizmet için bu, bu izinleri sağlayan yerleşik veya özel rolleri kullanarak Azure RBAC bir rol atamanız gerektiği anlamına gelir.

Önemli

Bazı izinler, tüm bağlamlar için gerekli olmayan hedef hizmet tarafından gösterilebilir. Mümkün olduğunda, kimliğe yalnızca gerekli ayrıcalıkları sağlayarak en az ayrıcalık ilkesine uyun. Örneğin, uygulamanın yalnızca bir veri kaynağından okuyabilmesi gerekiyorsa, yalnızca okuma izni olan bir rol kullanın. Okuma işlemi için aşırı izin olduğundan, bu hizmete yazmaya da izin veren bir rol atamak uygun olmaz. Benzer şekilde, rol atamasının kapsamının yalnızca okunması gereken kaynaklara göre ayarlandığından emin olmak istersiniz.

Çalışma zamanında olay hub'ınıza erişim sağlayan bir rol ataması oluşturmanız gerekir. Rol atamasının kapsamı bir Event Hubs ad alanı veya olay hub'ının kendisi için olabilir. Sahip gibi yönetim rolleri yeterli değildir. Aşağıdaki tabloda, Event Hubs uzantısı normal işlemde kullanılırken önerilen yerleşik roller gösterilmektedir. Uygulamanız, yazdığınız koda göre ek izinler gerektirebilir.

Bağlama türü	Örnek yerleşik roller
Tetikleyici	Azure Event Hubs Veri Alıcısı, Azure Event Hubs Veri Sahibi
Çıkış bağlaması	Azure Event Hubs Veri Gönderen

Olay hub'ını değil, namespace için Bağlantı Bilgileri düğmesine tıklayarak bu bağlantı dizesi alın. bağlantı dizesi, olay hub'ını değil event Hubs ad alanı için olmalıdır.

Tetikleyiciler için kullanıldığında, bağlantı dizesi işlevi etkinleştirmek için en az "okuma" izinlerine sahip olmalıdır. Çıkış bağlamaları için kullanıldığında, bağlantı dizesi olay akışına ileti göndermek için "gönderme" izinlerine sahip olmalıdır.

Bu bağlantı dizesi, bağlama yapılandırmasının connection özelliği tarafından belirtilen değerle eşleşen bir adla bir uygulama ayarında depolanmalıdır.

host.json ayarları

host.json dosyası Event Hubs tetikleyici davranışını denetleen ayarlar içerir. Kullanılabilir ayarlarla ilgili ayrıntılar için host.json ayarları bölümüne bakın.

Sonraki adımlar

Olay akışına olay yazma (Çıkış bağlama)

Geri Bildirim

Bu sayfayı yararlı buldunuz mu?

Last updated on 2026-04-14

Azure İşlevleri için Azure Event Hubs tetikleyicisi

Örnek

Özellikler

Dekoratörler

Ek Açıklamalar

Yapılandırma

Kullanım

Olay meta verileri

Bağlantılar

Kimliğe izin verme

host.json ayarları

Sonraki adımlar

Geri Bildirim

Ek kaynaklar