Azure İşlevleri için Azure Service Bus çı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.

Bu kod, öğesini ILoggertanımlar ve başlatır:

private readonly ILogger<ServiceBusReceivedMessageFunctions> _logger;

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

Bu örnekte, bir ileti alan ve ikinci kuyruğa yazan bir C# işlevi gösterilir:

[Function(nameof(ServiceBusReceivedMessageFunction))]
[ServiceBusOutput("outputQueue", Connection = "ServiceBusConnection")]
public string ServiceBusReceivedMessageFunction(
    [ServiceBusTrigger("queue", Connection = "ServiceBusConnection")] ServiceBusReceivedMessage message)
{
    _logger.LogInformation("Message ID: {id}", message.MessageId);
    _logger.LogInformation("Message Body: {body}", message.Body);
    _logger.LogInformation("Message Content-Type: {contentType}", message.ContentType);

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

Bu örnekte hem HTTP yanıtı göndermek hem de çıkış iletisini yazmak için nesne içeren OutputType bir HTTP tetikleyicisi kullanılır.

[Function("HttpSendMsg")]
public async Task<OutputType> Run([HttpTrigger(AuthorizationLevel.Function, "get", "post")] HttpRequestData req, FunctionContext context)
{
   _logger.LogInformation($"C# HTTP trigger function processed a request for {context.InvocationId}.");

   HttpResponseData response = req.CreateResponse(HttpStatusCode.OK);
   await response.WriteStringAsync("HTTP response: Message sent");

   return new OutputType()
   {
       OutputEvent = "MyMessage",
       HttpResponse = response
   };
}

Bu kod, üzerinde OutputEventService Bus çıkış bağlama tanımını içeren birden çok çıkış türünü OutputTypetanımlar:

 public class OutputType
{
   [ServiceBusOutput("TopicOrQueueName", Connection = "ServiceBusConnection")]
   public string OutputEvent { get; set; }

   public HttpResponseData HttpResponse { get; set; }
}

Aşağıdaki örnekte Service Bus kuyruk iletisi gönderen bir C# işlevi gösterilmektedir:

[FunctionName("ServiceBusOutput")]
[return: ServiceBus("myqueue", Connection = "ServiceBusConnection")]
public static string ServiceBusOutput([HttpTrigger] dynamic input, ILogger log)
{
    log.LogInformation($"C# function processed: {input.Text}");
    return input.Text;
}

bu HTTP tetikleyici işlevi, iletiyi göndermek için return deyimini kullanmak yerine çıkış iletisinden farklı bir HTTP yanıtı döndürür.

[FunctionName("HttpTrigger1")]
public static async Task<IActionResult> Run(
[HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req, 
[ServiceBus("TopicOrQueueName", Connection = "ServiceBusConnection")] IAsyncCollector<string> message, ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");

    await message.AddAsync("MyMessage");
    await message.AddAsync("MyMessage2");

    string responseMessage = "This HTTP triggered sent a message to Service Bus.";

    return new OkObjectResult(responseMessage);
}

Aşağıdaki örnekte, her 5 dakikada bir kuyruk iletisi gönderen bir zamanlayıcı tarafından 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.serviceBusQueue({
        queueName: 'testqueue',
        connection: 'MyServiceBusConnection',
    }),
    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, her 5 dakikada bir kuyruk iletisi gönderen zamanlayıcı tarafından tetiklenen JavaScript işlevi gösterilmektedir.

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

const serviceBusOutput = output.serviceBusQueue({
    queueName: 'testqueue',
    connection: 'MyServiceBusConnection',
});

app.timer('timerTrigger1', {
    schedule: '0 */5 * * * *',
    return: serviceBusOutput,
    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 service bus çıkış bağlaması ve bağlamayı kullanan bir JavaScript işlevi gösterilmektedir. İşlev, her 15 saniyede bir kuyruk iletisi göndermek için zamanlayıcı tetikleyicisi kullanır.

function.json dosyasındaki bağlama verileri aşağıdadır:

{
    "bindings": [
        {
            "schedule": "0/15 * * * * *",
            "name": "myTimer",
            "runsOnStartup": true,
            "type": "timerTrigger",
            "direction": "in"
        },
        {
            "name": "outputSbQueue",
            "type": "serviceBus",
            "queueName": "testqueue",
            "connection": "MyServiceBusConnection",
            "direction": "out"
        }
    ],
    "disabled": false
}

Tek bir ileti oluşturan JavaScript betik kodu aşağıdadır:

module.exports = async function (context, myTimer) {
    var message = 'Service Bus queue message created at ' + timeStamp;
    context.log(message);   
    context.bindings.outputSbQueue = message;
};

Birden çok ileti oluşturan JavaScript betik kodu aşağıdadır:

module.exports = async function (context, myTimer) {
    var message = 'Service Bus queue message created at ' + timeStamp;
    context.log(message);   
    context.bindings.outputSbQueue = [];
    context.bindings.outputSbQueue.push("1 " + message);
    context.bindings.outputSbQueue.push("2 " + message);
};

import logging
import azure.functions as func

app = func.FunctionApp()

@app.route(route="put_message")
@app.service_bus_topic_output(arg_name="message",
                              connection="<CONNECTION_SETTING>",
                              topic_name="<TOPIC_NAME>")
def main(req: func.HttpRequest, message: func.Out[str]) -> func.HttpResponse:
    input_msg = req.params.get('message')
    message.set(input_msg)
    return 'OK'

Service Bus bağlama tanımı, türün olarak ayarlandığı serviceBusfunction.json tanımlanır.

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "authLevel": "function",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": [
        "get",
        "post"
      ]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "$return"
    },
    {
      "type": "serviceBus",
      "direction": "out",
      "connection": "AzureServiceBusConnectionString",
      "name": "msg",
      "queueName": "outqueue"
    }
  ]
}

_init_.py'da, yöntemine bir değer set geçirerek kuyruğa bir ileti yazabilirsiniz.

import azure.functions as func

def main(req: func.HttpRequest, msg: func.Out[str]) -> func.HttpResponse:

    input_msg = req.params.get('message')

    msg.set(input_msg)

    return 'OK'

C# sınıf kitaplıklarında, çıkış tarafından yazılan kuyruğu veya konuyu tanımlamak için ServiceBusOutputAttribute'u kullanın.

Aşağıdaki tabloda özniteliğini kullanarak ayarlayabileceğiniz özellikler açıklanmaktadır:

C# sınıf kitaplıklarında ServiceBusAttribute kullanın.

Aşağıdaki tabloda özniteliğini kullanarak ayarlayabileceğiniz özellikler açıklanmaktadır:

İşlevin dönüş değerine uygulanan özniteliği gösteren bir örnek aşağıda verilmiştir:

[FunctionName("ServiceBusOutput")]
[return: ServiceBus("myqueue")]
public static string Run([HttpTrigger] dynamic input, ILogger log)
{
    ...
}

Özelliğini, aşağıdaki örnekte gösterildiği gibi kullanılacak Service Bus bağlantı dizesi içeren bir uygulama ayarının adını belirtecek şekilde ayarlayabilirsinizConnection:

[FunctionName("ServiceBusOutput")]
[return: ServiceBus("myqueue", Connection = "ServiceBusConnection")]
public static string Run([HttpTrigger] dynamic input, ILogger log)
{
    ...
}

Tam bir örnek için bkz . Örnek.

sınıfı, ServiceBusAccount yöntemi veya parametre düzeyinde kullanılacak Service Bus hesabını belirtmek için özniteliğini kullanabilirsiniz. Daha fazla bilgi için tetikleyici başvurusundaki Öznitelikler bölümüne bakın.

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

Aşağıdaki tabloda, yöntemine geçirilen output.serviceBusTopic() 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.

Meta verilerle ileti gönderirken ServiceBusMessage türünü kullanın. Parametreler tür öznitelikleri olarak return tanımlanır. ICollector<T> Birden çok ileti yazmak için veya IAsyncCollector<T> kullanın. yöntemini çağırdığınızda Add bir ileti oluşturulur.

İşlev çıktığında parametre değeri null olduğunda İşlevler ileti oluşturmaz.

Kullanılacak Service Bus hesabını belirtmek için ServiceBusAccountAttribute'u da kullanabilirsiniz. Oluşturucu, Service Bus bağlantı dizesi içeren bir uygulama ayarının adını alır. Özniteliği parametre, yöntem veya sınıf düzeyinde uygulanabilir. Aşağıdaki örnekte sınıf düzeyi ve yöntem düzeyi gösterilmektedir:

[ServiceBusAccount("ClassLevelServiceBusAppSetting")]
public static class AzureFunctions
{
    [ServiceBusAccount("MethodLevelServiceBusAppSetting")]
    [FunctionName("ServiceBusQueueTriggerCSharp")]
    public static void Run(
        [ServiceBusTrigger("myqueue", AccessRights.Manage)] 
        string myQueueItem, ILogger log)
{
    ...
}

Kullanılacak Service Bus hesabı aşağıdaki sırayla belirlenir:

• Özniteliğin ServiceBusTrigger Connection özelliği.
• özniteliğiyle ServiceBusAccount aynı parametreye uygulandı ServiceBusTrigger .
• ServiceBusAccount İşleve uygulanan öznitelik.
• ServiceBusAccount sınıfına uygulanan öznitelik.
• AzureWebJobsServiceBus Uygulama ayarı.

Meta verilerle ileti gönderirken İleti türünü kullanın. Parametreler tür öznitelikleri olarak return tanımlanır. ICollector<T> Birden çok ileti yazmak için veya IAsyncCollector<T> kullanın. yöntemini çağırdığınızda Add bir ileti oluşturulur.

30 Eylül 2026'da Azure SDK yönergelerine uymayan WindowsAzure.ServiceBus, Microsoft.Azure.ServiceBus ve com.microsoft.azure.servicebus Azure Service Bus SDK kitaplıklarını kullanımdan kaldıracağız. Ayrıca SBMP protokolünün desteğini de sonlandıracağız, bu nedenle 30 Eylül 2026'da bu protokolü artık kullanamayacaksınız. Bu tarihten önce kritik güvenlik güncelleştirmeleri ve geliştirilmiş özellikler sunan en son Azure SDK kitaplıklarına geçiş yapın.

Eski kitaplıklar 30 Eylül 2026'dan sonra da kullanılabilir olsa da artık Microsoft'tan resmi destek ve güncelleştirmeler almayacaktır. Daha fazla bilgi için bkz . destek kullanımdan kaldırma duyurusu.

İşlev çıktığında parametre değeri null olduğunda İşlevler ileti oluşturmaz.

Kullanılacak Service Bus hesabını belirtmek için ServiceBusAccountAttribute'u da kullanabilirsiniz. Oluşturucu, Service Bus bağlantı dizesi içeren bir uygulama ayarının adını alır. Özniteliği parametre, yöntem veya sınıf düzeyinde uygulanabilir. Aşağıdaki örnekte sınıf düzeyi ve yöntem düzeyi gösterilmektedir:

[ServiceBusAccount("ClassLevelServiceBusAppSetting")]
public static class AzureFunctions
{
    [ServiceBusAccount("MethodLevelServiceBusAppSetting")]
    [FunctionName("ServiceBusQueueTriggerCSharp")]
    public static void Run(
        [ServiceBusTrigger("myqueue", AccessRights.Manage)] 
        string myQueueItem, ILogger log)
{
    ...
}

Kullanılacak Service Bus hesabı aşağıdaki sırayla belirlenir:

• Özniteliğin ServiceBusTrigger Connection özelliği.
• özniteliğiyle ServiceBusAccount aynı parametreye uygulandı ServiceBusTrigger .
• ServiceBusAccount İşleve uygulanan öznitelik.
• ServiceBusAccount sınıfına uygulanan öznitelik.
• AzureWebJobsServiceBus Uygulama ayarı.

Meta verilerle ileti gönderirken BrokeredMessage türünü kullanın. Parametreler tür öznitelikleri olarak return tanımlanır. İşlev çıktığında parametre değeri null olduğunda İşlevler ileti oluşturmaz.

Kullanılacak Service Bus hesabını belirtmek için ServiceBusAccountAttribute'u da kullanabilirsiniz. Oluşturucu, Service Bus bağlantı dizesi içeren bir uygulama ayarının adını alır. Özniteliği parametre, yöntem veya sınıf düzeyinde uygulanabilir. Aşağıdaki örnekte sınıf düzeyi ve yöntem düzeyi gösterilmektedir:

[ServiceBusAccount("ClassLevelServiceBusAppSetting")]
public static class AzureFunctions
{
    [ServiceBusAccount("MethodLevelServiceBusAppSetting")]
    [FunctionName("ServiceBusQueueTriggerCSharp")]
    public static void Run(
        [ServiceBusTrigger("myqueue", AccessRights.Manage)] 
        string myQueueItem, ILogger log)
{
    ...
}

Kullanılacak Service Bus hesabı aşağıdaki sırayla belirlenir:

• Özniteliğin ServiceBusTrigger Connection özelliği.
• özniteliğiyle ServiceBusAccount aynı parametreye uygulandı ServiceBusTrigger .
• ServiceBusAccount İşleve uygulanan öznitelik.
• ServiceBusAccount sınıfına uygulanan öznitelik.
• AzureWebJobsServiceBus Uygulama ayarı.

İşlevin tek bir ileti yazmasını istediğinizde, Service Bus çıkış bağlaması aşağıdaki türlere bağlanabilir:

İşlevin birden çok ileti yazmasını istediğinizde, Service Bus çıkış bağlaması aşağıdaki türlere bağlanabilir:

Diğer çıkış senaryoları için, doğrudan Azure.Messaging.ServiceBus'tan diğer türlerle bir ServiceBusClient 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.

Yalıtılmış çalışan işleminde bu uzantının önceki sürümleri yalnızca mesajlaşmaya özgü türlere bağlamayı destekler. Uzantı 5.x ve üzeri için ek seçenekler sağlanır

İşlevler sürüm 1.x yalıtılmış çalışan işlemini desteklemez. Yalıtılmış çalışan modelini kullanmak için uygulamanızı İşlevler 4.x sürümüne yükseltin.

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ış iletisine name erişin.