Azure Functions에 대한 Azure Service Bus 출력 바인딩

Python v2 프로그래밍 모델을 사용하면 Python 함수 코드에서 직접 데코레이터를 사용하여 바인딩을 정의할 수 있습니다. 자세한 내용은 Python 개발자 가이드를 참조하세요.

Python v1 프로그래밍 모델을 사용하려면 함수 폴더의 별도 function.json 파일에서 바인딩을 정의해야 합니다. 자세한 내용은 Python 개발자 가이드를 참조하세요.

이 코드는 다음을 정의하고 초기화합니다.ILogger

private readonly ILogger<ServiceBusReceivedMessageFunctions> _logger;

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

이 예제에서는 메시지를 수신하고 두 번째 큐에 쓰는 C# 함수를 보여 줍니다.

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

이 예제에서는 개체와 함께 HTTP 트리거를 OutputType 사용하여 HTTP 응답을 보내고 출력 메시지를 작성합니다.

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

이 코드는 다음에 대한 Service Bus 출력 바인딩 정의를 포함하는 여러 출력 형식OutputType을 정의합니다.OutputEvent

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

   public HttpResponseData HttpResponse { get; set; }
}

다음 예제에서는 Service Bus 큐 메시지를 보내는 C# 함수를 보여줍니다.

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

이 HTTP 트리거 함수는 return 문을 사용하여 메시지를 보내는 대신 출력 메시지와 다른 HTTP 응답을 반환합니다.

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

다음 예에서는 5분마다 큐 메시지를 보내는 타이머 트리거 TypeScript 함수를 보여 줍니다.

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

여러 메시지를 출력하려면 단일 개체 대신 배열을 반환합니다. 예시:

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

TypeScript 샘플은 모델 v3에 대해 문서화되지 않습니다.

다음 예에서는 5분마다 큐 메시지를 보내는 타이머 트리거 JavaScript 함수를 보여 줍니다.

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

여러 메시지를 출력하려면 단일 개체 대신 배열을 반환합니다. 예시:

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

다음 예제에서는 function.json 파일의 Service Bus 출력 바인딩 및 바인딩을 사용하는 JavaScript 함수를 보여줍니다. 함수는 타이머 트리거를 사용하여 15초마다 큐 메시지를 보냅니다.

function.json 파일의 바인딩 데이터는 다음과 같습니다.

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

단일 메시지를 만드는 JavaScript 스크립트 코드는 다음과 같습니다.

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

다음은 여러 메시지를 만드는 JavaScript 스크립트 코드입니다.

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 바인딩은 형식이 serviceBus로 설정된 function.json에 정의됩니다.

{
  "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에서 set 메서드에 값을 전달하여 큐에 메시지를 쓸 수 있습니다.

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# 클래스 라이브러리에서 ServiceBusOutputAttribute를 사용하여 출력에 의해 작성된 큐 또는 항목을 정의합니다.

다음 표에서는 특성을 사용하여 설정할 수 있는 특성에 대해 설명합니다.

C# 클래스 라이브러리에서 ServiceBusAttribute를 사용합니다.

다음 표에서는 특성을 사용하여 설정할 수 있는 특성에 대해 설명합니다.

다음은 함수의 반환 값에 적용된 특성을 보여 주는 예제입니다.

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

다음 예제와 같이 사용할 Service Bus 연결 문자열 포함된 앱 설정의 이름을 지정하도록 속성을 설정할 Connection 수 있습니다.

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

전체 예제는 예제를 참조하세요.

특성을 사용하여 ServiceBusAccount 클래스, 메서드 또는 매개 변수 수준에서 사용할 Service Bus 계정을 지정할 수 있습니다. 자세한 내용은 트리거 참조에서 특성을 참조하세요.

다음 표에서는 output.serviceBusQueue() 메서드에 전달된 options 개체에 설정할 수 있는 속성에 대해 설명합니다.

다음 표에서는 output.serviceBusTopic() 메서드에 전달된 options 개체에 설정할 수 있는 속성에 대해 설명합니다.

다음 표에서는 function.json 파일에 설정된 바인딩 구성 속성을 설명합니다.

메타데이터가 포함된 메시지를 보낼 때 ServiceBusMessage 형식을 사용합니다. 매개 변수는 return 형식 특성으로 정의됩니다. 여러 메시지를 작성하려면 ICollector<T> 또는 IAsyncCollector<T>를 사용합니다. 메서드를 호출 Add 할 때 메시지가 만들어집니다.

함수가 종료될 때 매개 변수 값이 null이면 Functions는 메시지를 만들지 않습니다.

ServiceBusAccountAttribute를 사용하여 사용할 Service Bus 계정을 지정할 수도 있습니다. 생성자는 Service Bus 연결 문자열 포함하는 앱 설정의 이름을 사용합니다. 매개 변수, 메서드 또는 클래스 수준에서 특성을 적용할 수 있습니다. 다음 예제에서는 클래스 수준 및 메서드 수준을 보여줍니다.

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

사용할 Service Bus 계정은 다음 순서로 결정됩니다.

• ServiceBusTrigger 특성의 속성입니다Connection.
• ServiceBusTrigger 특성과 동일한 매개 변수에 적용된 ServiceBusAccount 특성
• ServiceBusAccount 함수에 적용된 특성입니다.
• ServiceBusAccount 클래스에 적용된 특성입니다.
• AzureWebJobsServiceBus 앱 설정입니다.

메타데이터가 포함된 메시지를 보낼 때 Message 형식을 사용합니다. 매개 변수는 return 형식 특성으로 정의됩니다. 여러 메시지를 작성하려면 ICollector<T> 또는 IAsyncCollector<T>를 사용합니다. 메서드를 호출 Add 할 때 메시지가 만들어집니다.

2026년 9월 30일에 Azure SDK 지침을 따르지 않는 Azure Service Bus SDK 라이브러리 WindowsAzure.ServiceBus, Microsoft.Azure.ServiceBus 및 com.microsoft.azure.servicebus를 사용 중지합니다. 또한 SBMP 프로토콜에 대한 지원이 종료되므로 2026년 9월 30일 이후에는 더 이상 이 프로토콜을 사용할 수 없습니다. 해당 날짜 마이그레이션에 중요한 보안 업데이트와 개선된 기능을 제공하는 최신 Azure SDK 라이브러리로 마이그레이션합니다.

이전 라이브러리는 2026년 9월 30일 이후에도 계속 사용할 수 있지만 더 이상 Microsoft로부터 공식 지원 및 업데이트를 받을 수 없습니다. 자세한 내용은 사용 중지 공지 지원을 참조하세요.

함수가 종료될 때 매개 변수 값이 null이면 Functions는 메시지를 만들지 않습니다.

ServiceBusAccountAttribute를 사용하여 사용할 Service Bus 계정을 지정할 수도 있습니다. 생성자는 Service Bus 연결 문자열 포함하는 앱 설정의 이름을 사용합니다. 매개 변수, 메서드 또는 클래스 수준에서 특성을 적용할 수 있습니다. 다음 예제에서는 클래스 수준 및 메서드 수준을 보여줍니다.

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

사용할 Service Bus 계정은 다음 순서로 결정됩니다.

• ServiceBusTrigger 특성의 속성입니다Connection.
• ServiceBusTrigger 특성과 동일한 매개 변수에 적용된 ServiceBusAccount 특성
• ServiceBusAccount 함수에 적용된 특성입니다.
• ServiceBusAccount 클래스에 적용된 특성입니다.
• AzureWebJobsServiceBus 앱 설정입니다.

메타데이터가 포함된 메시지를 보낼 때 BrokeredMessage 형식을 사용합니다. 매개 변수는 return 형식 특성으로 정의됩니다. 함수가 종료될 때 매개 변수 값이 null이면 Functions는 메시지를 만들지 않습니다.

ServiceBusAccountAttribute를 사용하여 사용할 Service Bus 계정을 지정할 수도 있습니다. 생성자는 Service Bus 연결 문자열 포함하는 앱 설정의 이름을 사용합니다. 매개 변수, 메서드 또는 클래스 수준에서 특성을 적용할 수 있습니다. 다음 예제에서는 클래스 수준 및 메서드 수준을 보여줍니다.

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

사용할 Service Bus 계정은 다음 순서로 결정됩니다.

• ServiceBusTrigger 특성의 속성입니다Connection.
• ServiceBusTrigger 특성과 동일한 매개 변수에 적용된 ServiceBusAccount 특성
• ServiceBusAccount 함수에 적용된 특성입니다.
• ServiceBusAccount 클래스에 적용된 특성입니다.
• AzureWebJobsServiceBus 앱 설정입니다.

함수가 단일 메시지를 작성하도록 하려는 경우 Service Bus 출력 바인딩은 다음 형식에 바인딩될 수 있습니다.

함수가 여러 메시지를 쓰도록 하려는 경우 Service Bus 출력 바인딩을 다음 형식에 바인딩할 수 있습니다.

다른 출력 시나리오의 경우 Azure.Messaging.ServiceBus의 다른 형식과 함께 ServiceBusClient를 직접 만들고 사용합니다. 종속성 주입을 사용하여 Azure SDK에서 클라이언트 형식을 만드는 예제는 Azure 클라이언트 등록을 참조하세요.

격리된 작업자 프로세스에 있는 이 확장의 이전 버전은 메시징 관련 형식에 대한 바인딩만 지원합니다. 확장 5.x 이상에서 더 많은 옵션을 사용할 수 있습니다.

Functions 버전 1.x는 격리된 작업자 프로세스를 지원하지 않습니다. 격리된 작업자 모델을 사용하려면 애플리케이션을 Functions 4.x로 업그레이드합니다.

값을 직접 반환하거나 context.extraOutputs.set()를 사용하여 출력 메시지에 액세스합니다.

context.bindings.<name>을 사용하여 출력 메시지에 액세스합니다. 여기서 <name>은 function.json의 name 속성에 지정된 값입니다.