Azure Functions の Azure Service Bus トリガー

[アーティクル]
10/27/2023

Service Bus トリガーを使用して、Service Bus キューまたはトピックからのメッセージに応答します。拡張機能バージョン 3.1.0 以降では、セッションが有効なキューまたはトピックでトリガーを実行できます。

セットアップと構成の詳細については、概要に関するページをご覧ください。

従量課金プランと Premium プランに対する Service Bus のスケーリングの決定は、ターゲットベースのスケーリングによって行われます。詳しくは、「ターゲットベースのスケーリング」をご覧ください。

重要

この記事では、タブを使用して、Node.js プログラミングモデルの複数のバージョンに対応しています。 v4 モデルは一般提供されており、JavaScript と TypeScript の開発者にとって、より柔軟で直感的なエクスペリエンスが得られるように設計されています。 v4 モデルの動作の詳細については、Azure Functions Node.js 開発者ガイドを参照してください。 v3 と v4 の違いの詳細については、移行ガイドを参照してください。

Azure Functions では、Python の 2 つのプログラミングモデルがサポートされています。バインドを定義する方法は、選択したプログラミングモデルによって異なります。

Python v2 プログラミングモデルでは、Python 関数コードでデコレーターを使用してバインドを直接定義できます。詳細については、「Python 開発者ガイド」を参照してください。

この記事は、両方のプログラミングモデルをサポートしています。

例

A C# 関数は、次の C# モードのいずれかを使用して作成できます。

分離されたワーカーモデル: ランタイムから分離されたワーカープロセスで実行されるコンパイル済みの C# 関数。分離ワーカープロセスは、LTS および非 LTS バージョンの .NET および .NET Framework で実行されている C# 関数をサポートするために必要です。分離ワーカープロセス関数の拡張機能では、Microsoft.Azure.Functions.Worker.Extensions.* 名前空間が使用されます。
インプロセスモデル: Functions ランタイムと同じプロセスで実行されるコンパイル済みの C# 関数。このモデルの一部では、主に C# ポータルの編集のためにサポートされている C# スクリプトを使用して Functions を実行できます。インプロセス関数の拡張機能では、Microsoft.Azure.WebJobs.Extensions.* 名前空間が使用されます。

重要

インプロセスモデルのサポートは 2026 年 11 月 10 日に終了します。完全なサポートのために、アプリを分離ワーカーモデルに移行することを強くお勧めします。

分離ワーカーモデル
インプロセスモデル

このコードにより、ILogger が定義され初期化されます。

private readonly ILogger<ServiceBusReceivedMessageFunctions> _logger;

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

この例では、1 つの Service Bus キューメッセージを受信し、それをログに書き込む 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;
}

この例では、1 つのバッチで複数の Service Bus キューメッセージを受信し、それぞれをログに書き込む C# 関数を示します。

[Function(nameof(ServiceBusReceivedMessageBatchFunction))]
public void ServiceBusReceivedMessageBatchFunction(
    [ServiceBusTrigger("queue", Connection = "ServiceBusConnection", IsBatched = true)] ServiceBusReceivedMessage[] messages)
{
    foreach (ServiceBusReceivedMessage message in messages)
    {
        _logger.LogInformation("Message ID: {id}", message.MessageId);
        _logger.LogInformation("Message Body: {body}", message.Body);
        _logger.LogInformation("Message Content-Type: {contentType}", message.ContentType);
    }
}

この例では、複数の Service Bus キューメッセージを受信し、ログに書き込み、その後メッセージを完了させる C# 関数を示します。

[Function(nameof(ServiceBusMessageActionsFunction))]
public async Task ServiceBusMessageActionsFunction(
    [ServiceBusTrigger("queue", Connection = "ServiceBusConnection", AutoCompleteMessages = false)]
    ServiceBusReceivedMessage message,
    ServiceBusMessageActions messageActions)
{
    _logger.LogInformation("Message ID: {id}", message.MessageId);
    _logger.LogInformation("Message Body: {body}", message.Body);
    _logger.LogInformation("Message Content-Type: {contentType}", message.ContentType);

    // Complete the message
    await messageActions.CompleteMessageAsync(message);
}

次の例は、メッセージメタデータを読み取り、Service Bus キューメッセージをログに記録する C# 関数を示しています。

[FunctionName("ServiceBusQueueTriggerCSharp")]                    
public static void Run(
    [ServiceBusTrigger("myqueue", Connection = "ServiceBusConnection")] 
    string myQueueItem,
    Int32 deliveryCount,
    DateTime enqueuedTimeUtc,
    string messageId,
    ILogger log)
{
    log.LogInformation($"C# ServiceBus queue trigger function processed message: {myQueueItem}");
    log.LogInformation($"EnqueuedTimeUtc={enqueuedTimeUtc}");
    log.LogInformation($"DeliveryCount={deliveryCount}");
    log.LogInformation($"MessageId={messageId}");
}

次の Java 関数は、@ServiceBusQueueTriggerからの @ServiceBusQueueTrigger 注釈を使用して、Service Bus キュートリガーの構成について記述します。この関数は、キューにあるメッセージを取得し、ログに追加します。

@FunctionName("sbprocessor")
 public void serviceBusProcess(
    @ServiceBusQueueTrigger(name = "msg",
                             queueName = "myqueuename",
                             connection = "myconnvarname") String message,
   final ExecutionContext context
 ) {
     context.getLogger().info(message);
 }

Service Bus トピックにメッセージが追加されたときに、Java 関数もトリガーできます。次の例では、トリガー構成を記述する @ServiceBusTopicTrigger 注釈を使用します。

@FunctionName("sbtopicprocessor")
    public void run(
        @ServiceBusTopicTrigger(
            name = "message",
            topicName = "mytopicname",
            subscriptionName = "mysubscription",
            connection = "ServiceBusConnection"
        ) String message,
        final ExecutionContext context
    ) {
        context.getLogger().info(message);
    }

モデル v4
モデル v3

次の例は、Service Bus トリガーの TypeScript 関数を示しています。この機能はメッセージメタデータを読み取り、Service Bus のキューメッセージをログに記録します。

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

export async function serviceBusQueueTrigger1(message: unknown, context: InvocationContext): Promise<void> {
    context.log('Service bus queue function processed message:', message);
    context.log('EnqueuedTimeUtc =', context.triggerMetadata.enqueuedTimeUtc);
    context.log('DeliveryCount =', context.triggerMetadata.deliveryCount);
    context.log('MessageId =', context.triggerMetadata.messageId);
}

app.serviceBusQueue('serviceBusQueueTrigger1', {
    connection: 'MyServiceBusConnection',
    queueName: 'testqueue',
    handler: serviceBusQueueTrigger1,
});

モデル v4
モデル v3

次の例は、Service Bus トリガーの JavaScript 関数を示しています。この機能はメッセージメタデータを読み取り、Service Bus のキューメッセージをログに記録します。

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

app.serviceBusQueue('serviceBusQueueTrigger1', {
    connection: 'MyServiceBusConnection',
    queueName: 'testqueue',
    handler: (message, context) => {
        context.log('Service bus queue function processed message:', message);
        context.log('EnqueuedTimeUtc =', context.triggerMetadata.enqueuedTimeUtc);
        context.log('DeliveryCount =', context.triggerMetadata.deliveryCount);
        context.log('MessageId =', context.triggerMetadata.messageId);
    },
});

次の例は、function.json ファイルの Service Bus トリガーバインドと、そのバインドが使用される JavaScript 関数を示しています。この機能はメッセージメタデータを読み取り、Service Bus のキューメッセージをログに記録します。

function.json ファイルのバインディングデータを次に示します。

{
"bindings": [
    {
    "queueName": "testqueue",
    "connection": "MyServiceBusConnection",
    "name": "myQueueItem",
    "type": "serviceBusTrigger",
    "direction": "in"
    }
],
"disabled": false
}

JavaScript スクリプトコードを次に示します。

module.exports = async function(context, myQueueItem) {
    context.log('Node.js ServiceBus queue trigger function processed message', myQueueItem);
    context.log('EnqueuedTimeUtc =', context.bindingData.enqueuedTimeUtc);
    context.log('DeliveryCount =', context.bindingData.deliveryCount);
    context.log('MessageId =', context.bindingData.messageId);
};

次の例は、function.json ファイル内の Service Bus トリガーバインディングと、そのバインディングを使用する PowerShell 関数を示しています。

function.json ファイルのバインディングデータを次に示します。

{
  "bindings": [
    {
      "name": "mySbMsg",
      "type": "serviceBusTrigger",
      "direction": "in",
      "topicName": "mytopic",
      "subscriptionName": "mysubscription",
      "connection": "AzureServiceBusConnectionString"
    }
  ]
}

Service Bus メッセージが送信されたときに実行される関数を次に示します。

param([string] $mySbMsg, $TriggerMetadata)

Write-Host "PowerShell ServiceBus queue trigger function processed message: $mySbMsg"

次の例では、トリガーを使用して ServiceBus キューメッセージを読み取る方法を示します。この例は、v1 と v2 のどちらの Python プログラミングモデルを使用するかによって異なります。

import logging
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="ServiceBusQueueTrigger1")
@app.service_bus_queue_trigger(arg_name="msg", 
                               queue_name="<QUEUE_NAME>", 
                               connection="<CONNECTION_SETTING>")
def test_function(msg: func.ServiceBusMessage):
    logging.info('Python ServiceBus queue trigger processed message: %s',
                 msg.get_body().decode('utf-8'))

Service Bus のバインディングは function.json で定義されます。そこでは type は serviceBusTrigger に設定され、キューは queueName によって設定されます。

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "msg",
      "type": "serviceBusTrigger",
      "direction": "in",
      "queueName": "inputqueue",
      "connection": "AzureServiceBusConnectionString"
    }
  ]
}

_init_.py のコードによってパラメーターが func.ServiceBusMessage として宣言され、関数でキューメッセージを読み取ることができるようになります。

import azure.functions as func

import logging
import json

def main(msg: func.ServiceBusMessage):
    logging.info('Python ServiceBus queue trigger processed message.')

    result = json.dumps({
        'message_id': msg.message_id,
        'body': msg.get_body().decode('utf-8'),
        'content_type': msg.content_type,
        'expiration_time': msg.expiration_time,
        'label': msg.label,
        'partition_key': msg.partition_key,
        'reply_to': msg.reply_to,
        'reply_to_session_id': msg.reply_to_session_id,
        'scheduled_enqueue_time': msg.scheduled_enqueue_time,
        'session_id': msg.session_id,
        'time_to_live': msg.time_to_live,
        'to': msg.to,
        'user_properties': msg.user_properties,
        'metadata' : msg.metadata
    }, default=str)

    logging.info(result)

次の例では、トリガーを使用して ServiceBus キュートピックを読み取る方法を示します。

import logging
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="ServiceBusTopicTrigger1")
@app.service_bus_topic_trigger(arg_name="message", 
                               topic_name="TOPIC_NAME", 
                               connection="CONNECTION_SETTING", 
                               subscription_name="SUBSCRIPTION_NAME")
def test_function(message: func.ServiceBusMessage):
    message_body = message.get_body().decode("utf-8")
    logging.info("Python ServiceBus topic trigger processed message.")
    logging.info("Message Body: " + message_body)

Service Bus のバインディングは function.json で定義されます。そこでは type は serviceBusTrigger に設定され、トピックは topicName によって設定されます。

{
  "scriptFile": "__init__.py",
  "bindings": [
   {
     "type": "serviceBusTrigger",
     "direction": "in",
     "name": "msg",
     "topicName": "inputtopic",
     "connection": "AzureServiceBusConnectionString"
   }
  ]
}

_init_.py のコードは、パラメーターを func.ServiceBusMessage として宣言します。これにより、関数でトピックを読み取ることができます。

import json

import azure.functions as azf


def main(msg: azf.ServiceBusMessage) -> str:
    result = json.dumps({
        'message_id': msg.message_id,
        'body': msg.get_body().decode('utf-8'),
        'content_type': msg.content_type,
        'delivery_count': msg.delivery_count,
        'expiration_time': (msg.expiration_time.isoformat() if
                            msg.expiration_time else None),
        'label': msg.label,
        'partition_key': msg.partition_key,
        'reply_to': msg.reply_to,
        'reply_to_session_id': msg.reply_to_session_id,
        'scheduled_enqueue_time': (msg.scheduled_enqueue_time.isoformat() if
                                   msg.scheduled_enqueue_time else None),
        'session_id': msg.session_id,
        'time_to_live': msg.time_to_live,
        'to': msg.to,
        'user_properties': msg.user_properties,
    })

    logging.info(result)

属性

インプロセスと分離ワーカープロセスの C# ライブラリはどちらも、ServiceBusTriggerAttribute 属性を使用して関数トリガーを定義します。 C# スクリプトでは、C# スクリプトガイドで説明されているように、代わりに function.json 構成ファイルを使用します。

分離ワーカーモデル
インプロセスモデル

次の表では、このトリガー属性を使用して設定できるプロパティについて説明します。

プロパティ	説明
QueueName	監視するキューの名前。トピックではなくキューを監視する場合にのみ設定します。
TopicName	監視するトピックの名前。キューではなくトピックを監視する場合にのみ設定します。
SubscriptionName	監視するサブスクリプションの名前。キューではなくトピックを監視する場合にのみ設定します。
接続	Service Bus への接続方法を指定するアプリ設定または設定コレクションの名前。「接続」を参照してください。
IsBatched	メッセージはバッチで配信されます。配列またはコレクション型が必要です。
IsSessionsEnabled	`true`キューまたはサブスクリプションに接続する場合は `true`。それ以外の場合は `false` (既定値)。
AutoCompleteMessages	`true` トリガーが正常に呼び出された後にメッセージを自動的に完了する必要がある場合は。 `false`そうでない場合は、コードでメッセージ決済を処理する場合などです。明示的に設定しない場合、動作は次の構成`host.json`に`autoCompleteMessages`基づいて行われます。

次の表では、このトリガー属性を使用して設定できるプロパティについて説明します。

プロパティ	説明
QueueName	監視するキューの名前。トピックではなくキューを監視する場合にのみ設定します。
TopicName	監視するトピックの名前。キューではなくトピックを監視する場合にのみ設定します。
SubscriptionName	監視するサブスクリプションの名前。キューではなくトピックを監視する場合にのみ設定します。
接続	Service Bus への接続方法を指定するアプリ設定または設定コレクションの名前。「接続」を参照してください。
Access (アクセス)	接続文字列のアクセス権。使用できる値は `manage` と `listen` です。既定値は `manage` で、`connection` が`manage`アクセス許可を持つことを示します。管理アクセス許可を持たない接続文字列を使用する場合は、`accessRights` を "listen" に設定します。設定しないと、Functions ランタイムが管理権限を必要とする操作の試行に失敗する可能性があります。最新バージョンの Service Bus SDK が管理の操作をサポートしていないため、Azure Functions バージョン 2.x 以降ではこのプロパティを利用できません。
IsBatched	メッセージはバッチで配信されます。配列またはコレクション型が必要です。
IsSessionsEnabled	`true`キューまたはサブスクリプションに接続する場合は `true`。それ以外の場合は `false` (既定値)。
オートコンプリート	`true`トリガーが処理後に自動的に complete を呼び出す必要があるか、または関数コードで complete を手動で呼び出すかどうか。 `true` に設定した場合、関数の実行が正常に完了するとトリガーによって自動的にメッセージが完了され、それ以外の場合はメッセージが破棄されます。 `false` に設定する場合は、自分で ServiceBusReceiver を呼び出して、メッセージ、セッション、またはバッチを完了、破棄、または配信不能にする必要があります。例外がスローされた場合 (かつ `ServiceBusReceiver` メソッドが呼び出されなかった場合)、ロックは維持されます。ロックが期限切れになると、メッセージはキューに再登録されて `DeliveryCount` はインクリメントされ、ロックは自動的に更新されます。

ローカルで開発する場合は、Values コレクション内の local.settings.json ファイルにアプリケーション設定を追加します。

デコレーター

Python v2 プログラミングモデルにのみ適用されます。

デコレータを使用して定義された Python v2 関数の場合、service_bus_queue_trigger に次のプロパティがあります。

プロパティ	説明
`arg_name`	関数コード内のキューまたはトピックメッセージを表す変数の名前。
`queue_name`	監視するキューの名前。トピックではなくキューを監視する場合にのみ設定します。
`connection`	Service Bus への接続方法を指定するアプリ設定または設定コレクションの名前。「接続」を参照してください。

function.json を使用して定義された Python 関数については、[構成] セクションを参照してください。

注釈

ServiceBusQueueTrigger 注釈を使用すると、Service Bus キューメッセージの作成時に実行される関数を作成できます。使用可能な構成オプションには、次のプロパティがあります。

プロパティ	内容
name	関数コード内のキューまたはトピックメッセージを表す変数の名前。
queueName	監視するキューの名前。トピックではなくキューを監視する場合にのみ設定します。
topicName	監視するトピックの名前。キューではなくトピックを監視する場合にのみ設定します。
subscriptionName	監視するサブスクリプションの名前。キューではなくトピックを監視する場合にのみ設定します。
connection	Service Bus への接続方法を指定するアプリ設定または設定コレクションの名前。「接続」を参照してください。

ServiceBusTopicTrigger 注釈を使用すると、関数をトリガーするデータを対象とするトピックとサブスクリプションを指定できます。

ローカルで開発する場合は、Values コレクション内の local.settings.json ファイルにアプリケーション設定を追加します。

詳細については、トリガーの例を参照してください。

構成

"Python v1 プログラミングモデルにのみ適用されます。"

モデル v4
モデル v3

次の表では、app.serviceBusQueue() または app.serviceBusTopic() メソッドに渡される options オブジェクトに対して設定できるプロパティについて説明します。

プロパティ	説明
queueName	監視するキューの名前。トピックではなくキューを監視する場合にのみ設定します。
topicName	監視するトピックの名前。キューではなくトピックを監視する場合にのみ設定します。
subscriptionName	監視するサブスクリプションの名前。キューではなくトピックを監視する場合にのみ設定します。
connection	Service Bus への接続方法を指定するアプリ設定または設定コレクションの名前。「接続」を参照してください。
accessRights	接続文字列のアクセス権。使用できる値は `manage` と `listen` です。既定値は `manage` で、`connection` が`manage`アクセス許可を持つことを示します。管理アクセス許可を持たない接続文字列を使用する場合は、`accessRights` を "listen" に設定します。設定しないと、Functions ランタイムが管理権限を必要とする操作の試行に失敗する可能性があります。最新バージョンの Service Bus SDK が管理の操作をサポートしていないため、Azure Functions バージョン 2.x 以降ではこのプロパティを利用できません。
isSessionsEnabled	`true`キューまたはサブスクリプションに接続する場合は `true`。それ以外の場合は `false` (既定値)。
autoComplete	C# 以外の関数の場合は `true` である必要があります。これは、トリガーが処理後に complete を自動的に呼び出すか、関数コードが手動で complete を呼び出す必要があることを意味します。 `true` に設定した場合、関数の実行が正常に完了すると、トリガーによって自動的にメッセージが完了され、それ以外の場合はメッセージが破棄されます。関数で例外が発生すると、ランタイムによってバックグラウンドで `abandonAsync` が呼び出されます。例外が発生しなかった場合は、バックグラウンドで `completeAsync` が呼び出されます。このプロパティは Azure Functions 2.x 以降でのみ利用できます。

次の表は、function.json ファイルで設定したバインド構成のプロパティを説明しています。

プロパティ	説明
type	`serviceBusTrigger` に設定する必要があります。このプロパティは、Azure Portal でトリガーを作成するときに自動で設定されます。
direction	"in" に設定する必要があります。このプロパティは、Azure Portal でトリガーを作成するときに自動で設定されます。
name	関数コード内のキューまたはトピックメッセージを表す変数の名前。
queueName	監視するキューの名前。トピックではなくキューを監視する場合にのみ設定します。
topicName	監視するトピックの名前。キューではなくトピックを監視する場合にのみ設定します。
subscriptionName	監視するサブスクリプションの名前。キューではなくトピックを監視する場合にのみ設定します。
connection	Service Bus への接続方法を指定するアプリ設定または設定コレクションの名前。「接続」を参照してください。
accessRights	接続文字列のアクセス権。使用できる値は `manage` と `listen` です。既定値は `manage` で、`connection` が`manage`アクセス許可を持つことを示します。管理アクセス許可を持たない接続文字列を使用する場合は、`accessRights` を "listen" に設定します。設定しないと、Functions ランタイムが管理権限を必要とする操作の試行に失敗する可能性があります。最新バージョンの Service Bus SDK が管理の操作をサポートしていないため、Azure Functions バージョン 2.x 以降ではこのプロパティを利用できません。
isSessionsEnabled	`true`キューまたはサブスクリプションに接続する場合は `true`。それ以外の場合は `false` (既定値)。
autoComplete	C# 以外の関数の場合は `true` である必要があります。これは、トリガーが処理後に complete を自動的に呼び出すか、関数コードが手動で complete を呼び出す必要があることを意味します。 `true` に設定した場合、関数の実行が正常に完了すると、トリガーによって自動的にメッセージが完了され、それ以外の場合はメッセージが破棄されます。関数で例外が発生すると、ランタイムによってバックグラウンドで `abandonAsync` が呼び出されます。例外が発生しなかった場合は、バックグラウンドで `completeAsync` が呼び出されます。このプロパティは Azure Functions 2.x 以降でのみ利用できます。

ローカルで開発する場合は、Values コレクション内の local.settings.json ファイルにアプリケーション設定を追加します。

次の表は、function.json ファイルで設定したバインド構成のプロパティを説明しています。

function.json のプロパティ	説明
type	`serviceBusTrigger` に設定する必要があります。このプロパティは、Azure Portal でトリガーを作成するときに自動で設定されます。
direction	"in" に設定する必要があります。このプロパティは、Azure Portal でトリガーを作成するときに自動で設定されます。
name	関数コード内のキューまたはトピックメッセージを表す変数の名前。
queueName	監視するキューの名前。トピックではなくキューを監視する場合にのみ設定します。
topicName	監視するトピックの名前。キューではなくトピックを監視する場合にのみ設定します。
subscriptionName	監視するサブスクリプションの名前。キューではなくトピックを監視する場合にのみ設定します。
connection	Service Bus への接続方法を指定するアプリ設定または設定コレクションの名前。「接続」を参照してください。
accessRights	接続文字列のアクセス権。使用できる値は `manage` と `listen` です。既定値は `manage` で、`connection` が`manage`アクセス許可を持つことを示します。管理アクセス許可を持たない接続文字列を使用する場合は、`accessRights` を "listen" に設定します。設定しないと、Functions ランタイムが管理権限を必要とする操作の試行に失敗する可能性があります。最新バージョンの Service Bus SDK が管理の操作をサポートしていないため、Azure Functions バージョン 2.x 以降ではこのプロパティを利用できません。
isSessionsEnabled	`true`キューまたはサブスクリプションに接続する場合は `true`。それ以外の場合は `false` (既定値)。
autoComplete	C# 以外の関数の場合は `true` である必要があります。これは、トリガーが処理後に complete を自動的に呼び出すか、関数コードが手動で complete を呼び出す必要があることを意味します。 `true` に設定した場合、関数の実行が正常に完了すると、トリガーによって自動的にメッセージが完了され、それ以外の場合はメッセージが破棄されます。関数で例外が発生すると、ランタイムによってバックグラウンドで `abandonAsync` が呼び出されます。例外が発生しなかった場合は、バックグラウンドで `completeAsync` が呼び出されます。このプロパティは Azure Functions 2.x 以降でのみ利用できます。

ローカルで開発する場合は、Values コレクション内の local.settings.json ファイルにアプリケーション設定を追加します。

完全な例については、セクションの例を参照してください。

使用方法

次のパラメーター型は、すべての C# モダリティと拡張機能バージョンでサポートされています。

Type	説明
System.String	メッセージが単純なテキストである場合に使用します。
byte[]	バイナリデータメッセージに使用します。
Object	メッセージに JSON が含まれている場合、Functions は JSON データを既知の plain-old CLR オブジェクト型に逆シリアル化しようとします。

メッセージング固有のパラメーター型には、追加のメッセージメタデータが含まれます。 Service Bus トリガーによってサポートされる特定の型は、Functions Runtime のバージョン、拡張機能パッケージのバージョン、および使用される C# のモダリティによって異なります。

ServiceBusReceivedMessage 型を使用して、Service Bus キューとサブスクリプションからメッセージメタデータを受信します。詳細については、「メッセージ、ペイロード、およびシリアル化」を参照してください。

C# クラスライブラリでは、属性のコンストラクターは、キューの名前、またはトピックとサブスクリプションを受け取ります。

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 アプリ設定。

メッセージ型を使用して、メタデータを含むメッセージを受信します。詳細については、「メッセージ、ペイロード、およびシリアル化」を参照してください。

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 から公式のサポートと更新プログラムは提供されなくなります。詳細については、サポート廃止のお知らせに関するページを参照してください。

C# クラスライブラリでは、属性のコンストラクターは、キューの名前、またはトピックとサブスクリプションを受け取ります。

[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 - BrokeredMessage.GetBody<T>() メソッドで逆シリアル化されたメッセージを返します。
MessageReceiver - メッセージコンテナーからのメッセージを受信および確認するために使用し、autoComplete が false に設定されている場合に必要です。

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 から公式のサポートと更新プログラムは提供されなくなります。詳細については、サポート廃止のお知らせに関するページを参照してください。

C# クラスライブラリでは、属性のコンストラクターは、キューの名前、またはトピックとサブスクリプションを受け取ります。 Azure Functions バージョン 1.x では、接続のアクセス権を指定することもできます。アクセス権を指定しない場合、既定値は Manage になります。

[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 アプリ設定。

関数で 1 つのメッセージを処理するとき、Service Bus トリガーは次の型にバインドできます。

Type	説明
`string`	文字列としてのメッセージ。メッセージが単純なテキストである場合に使用します。
`byte[]`	メッセージのバイト数。
JSON シリアル化可能な型	イベントに JSON データが含まれている場合、Functions は JSON データを単純な従来の CLR オブジェクト (POCO) 型に逆シリアル化しようとします。
ServiceBusReceivedMessage¹	メッセージオブジェクト。バインド`ServiceBusReceivedMessage`する場合は、必要に応じて ServiceBusMessageActions^1,2 型のパラメーターを含め、メッセージ解決アクションを実行することもできます。

関数でメッセージのバッチを処理するとき、Service Bus トリガーは次の型にバインドできます。

Type	説明
`T[]` (`T` は単一メッセージ型の 1 つ)	バッチのイベントの配列。各エントリは 1 つのイベントを表します。バインド`ServiceBusReceivedMessage[]`する場合は、必要に応じて ServiceBusMessageActions^1,2 型のパラメーターを含め、メッセージ解決アクションを実行することもできます。

¹ これらの型を使用するには、Microsoft.Azure.Functions.Worker.Extensions.ServiceBus 5.14.1 以降と SDK 型バインドの一般的な依存関係に関する記事を参照する必要があります。

² 使用する場合は、AutoCompleteMessagesトリガー属性falseのプロパティServiceBusMessageActionsを . これにより、関数の呼び出しが成功した後にランタイムがメッセージを完了することを試みなくなります。

Connection プロパティが定義されていないとき、Functions は AzureWebJobsServiceBus という名前のアプリ設定を探します。これは Service Bus 接続文字列の既定の名前です。 Connection プロパティを設定して、使用する Service Bus 接続文字列を含むアプリケーション設定の名前を指定することもできます。

受信 Service Bus メッセージは、ServiceBusQueueMessage または ServiceBusTopicMessage パラメーターを使用して利用できます。

モデル v4
モデル v3

関数の最初の引数としてキューまたはトピックメッセージにアクセスします。 Service Bus メッセージが文字列または JSON オブジェクトとして関数に渡されます。

Service Bus インスタンスは、function.json ファイルの name プロパティで構成されているパラメーター経由で使用できます。

キューメッセージは、func.ServiceBusMessage として型指定されたパラメーターを介して関数で使用できます。 Service Bus メッセージが文字列または JSON オブジェクトとして関数に渡されます。

完全な例については、例のセクションを参照してください。

接続

connection プロパティは、アプリを Service Bus に接続する方法を指定する環境構成への参照です。次のものが指定されている場合があります。

接続文字列を含むアプリケーション設定の名前
まとめて ID ベースの接続を定義する、複数のアプリケーション設定の共有プレフィックスの名前。

構成された値が、1 つの設定に完全一致し、プレフィックスがその他の設定とも一致する場合は、完全一致が使用されます。

接続文字列

接続文字列は、管理資格情報の取得に関する記事の手順に従って取得します。接続文字列は、特定のキューまたはトピックに限らず、Service Bus 名前空間のものである必要があります。

この接続文字列は、バインディング構成の connection プロパティで指定した値と一致する名前のアプリケーション設定に格納する必要があります。

アプリ設定の名前が "AzureWebJobs" で始まる場合は、名前の残りの部分のみを指定できます。たとえば、connection を "MyServiceBus" に設定した場合、Functions ランタイムは "AzureWebJobsMyServiceBus" という名前のアプリ設定を探します。 connection を空のままにした場合、Functions ランタイムは、アプリ設定内の "AzureWebJobsServiceBus" という名前の既定の Service Bus 接続文字列を使用します。

ID ベースの接続

シークレットを含む接続文字列を使う代わりに、拡張機能のバージョン 5.x 以降を使用している場合は、アプリで Microsoft Entra ID を使用できます。これを行うには、トリガーおよびバインド構成の connection プロパティにマップされる共通のプレフィックスに設定を定義します。

このモードでは、拡張機能に次のプロパティが必要です。

プロパティ	環境変数テンプレート	説明	値の例
完全修飾名前空間	`<CONNECTION_NAME_PREFIX>__fullyQualifiedNamespace`	Service Bus の完全修飾名前空間。	<service_bus_namespace>.servicebus.windows.net

接続をカスタマイズするには、プロパティを追加設定します。「ID ベース接続に共通のプロパティ」を参照してください。

注意

Azure App Configuration または Key Vault を使用してマネージド ID 接続の設定を指定する場合、__ の代わりに : や / などの有効なキー区切り記号を使用して、名前が正しく解決されるようにしなければなりません。

たとえば、「 <CONNECTION_NAME_PREFIX>:fullyQualifiedNamespace 」のように入力します。

Azure Functions サービスでホストされている場合、ID ベースの接続では、マネージド ID が使用されます。ユーザー割り当て ID を credential および clientID プロパティで指定できますが、システム割り当て ID が既定で使用されます。リソース ID を使用したユーザー割り当て ID の構成はサポートされていないことに注意してください。ローカル開発などの他のコンテキストで実行する場合は、代わりに開発者 ID が使用されますが、カスタマイズすることもできます。 ID ベースの接続によるローカル開発に関するページをご覧ください。

ID にアクセス許可を付与する

使用されている ID が何であれ、目的のアクションを実行するためのアクセス許可が必要です。ほとんどの Azure では、これはそれらのアクセス許可を提供する組み込みロールまたはカスタムロールを使って、Azure RBAC でロールを割り当てる必要があることを意味します。

重要

すべてのコンテキストに必要ではない一部のアクセス許可がターゲットサービスによって公開される場合があります。可能であれば、最小限の特権の原則に従い、必要な特権だけを ID に付与します。たとえば、アプリがデータソースからの読み取りのみを行う必要がある場合は、読み取りアクセス許可のみを持つロールを使用します。サービスへの書き込みも可能なロールを割り当てることは、読み取り操作に対するアクセス許可が過剰になるため、不適切です。同様に、ロールの割り当てが、読み取る必要のあるリソースだけに限定されていることを確認する必要があります。

実行時にトピックとキューへのアクセスを提供するロールの割り当てを作成する必要があります。所有者のような管理ロールでは十分ではありません。次の表は、通常の操作で Service Bus の拡張機能を使用するときに推奨される組み込みロールを示しています。アプリケーションでは、記述したコードに基づいて追加のアクセス許可が必要になる場合があります。

[バインドの種類]	組み込みロールの例
トリガー ¹	Azure Service Bus データ受信者、Azure Service Bus データ所有者
出力バインド	Azure Service Bus データ送信者

¹ Service Bus トピックからのトリガーの場合、ロール割り当てには、Service Bus サブスクリプションリソースに対する有効なスコープが必要です。トピックだけが含まれている場合は、エラーが発生します。 Azure portal などの一部のクライアントは、ロール割り当てのスコープとして、Service Bus サブスクリプションリソースを公開しません。このような場合、代わりに Azure CLI を使用できます。詳しくは、「Azure Service Bus 用の Azure 組み込みロール」を参照してください。

有害メッセージ

Azure Functions では、有害メッセージの処理を制御することも構成することもできません。 Service Bus 自体で、有害なメッセージが処理されます。

PeekLock 動作

Functions ランタイムは、メッセージを PeekLock モードで受信します。

既定では、ランタイムは、関数が正常に終了した場合はメッセージを呼び出 Complete し、関数が失敗した場合は呼び出します Abandon 。でプロパティhost.jsonを使用して自動補完をautoCompleteMessages無効にすることができます。

既定では、ランタイムは、関数が正常に終了した場合はメッセージを呼び出 Complete し、関数が失敗した場合は呼び出します Abandon 。トリガー属性のプロパティ内 host.jsonまたはプロパティをautoCompleteMessages使用して、自動補完を無効にすることができます。関数コードがメッセージ決済を処理する場合は、自動補完を無効にする必要があります。

関数が実行されている限り、関数の実行時間が PeekLock タイムアウトよりも長くなると、ロックが自動的に更新されます。 maxAutoRenewDuration は host.json で構成可能であり、これは ServiceBusProcessor.MaxAutoLockRenewalDuration にマップされます。この設定の既定値は 5 分です。

メッセージのメタデータ

メッセージング固有の型を使用すると、オブジェクトのプロパティとしてメタデータを簡単に取得できます。これらのプロパティは、Functions ランタイムのバージョン、拡張機能パッケージのバージョン、および使用される C# のモダリティによって異なります。

これらのプロパティは ServiceBusReceivedMessage クラスのメンバーです。

プロパティ	タイプ	説明
`ApplicationProperties`	`ApplicationProperties`	送信者によって設定されたプロパティ。
`ContentType`	`string`	アプリケーション固有のロジックのために送信者と受信者が利用するコンテンツタイプ識別子。
`CorrelationId`	`string`	関連付け ID。
`DeliveryCount`	`Int32`	配信回数。
`EnqueuedTime`	`DateTime`	エンキューされた時刻 (UTC)。
`ScheduledEnqueueTimeUtc`	`DateTime`	スケジュールされたエンキュー時刻 (UTC)。
`ExpiresAt`	`DateTime`	有効期限 (UTC)。
`MessageId`	`string`	有効になっている場合に、重複するメッセージを識別するために Service Bus が使用できるユーザー定義の値
`ReplyTo`	`string`	キューアドレスへの返信。
`Subject`	`string`	`Label` メタデータプロパティの代わりに使用できるアプリケーション固有のラベル。
`To`	`string`	送信先アドレス。

これらのプロパティは Message クラスのメンバーです。

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 から公式のサポートと更新プログラムは提供されなくなります。詳細については、サポート廃止のお知らせに関するページを参照してください。

プロパティ	タイプ	説明
`ContentType`	`string`	アプリケーション固有のロジックのために送信者と受信者が利用するコンテンツタイプ識別子。
`CorrelationId`	`string`	関連付け ID。
`DeliveryCount`	`Int32`	配信回数。
`ScheduledEnqueueTimeUtc`	`DateTime`	スケジュールされたエンキュー時刻 (UTC)。
`ExpiresAtUtc`	`DateTime`	有効期限 (UTC)。
`Label`	`string`	アプリケーション固有のラベル。
`MessageId`	`string`	有効になっている場合に、重複するメッセージを識別するために Service Bus が使用できるユーザー定義の値
`ReplyTo`	`string`	キューアドレスへの返信。
`To`	`string`	送信先アドレス。
`UserProperties`	`IDictionary<string, object>`	送信者によって設定されたプロパティ。

これらのプロパティは、Brokeredmessage クラスと MessageReceiver クラスのメンバーです。

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 から公式のサポートと更新プログラムは提供されなくなります。詳細については、サポート廃止のお知らせに関するページを参照してください。

プロパティ	タイプ	説明
`ContentType`	`string`	アプリケーション固有のロジックのために送信者と受信者が利用するコンテンツタイプ識別子。
`CorrelationId`	`string`	関連付け ID。
`DeadLetterSource`	`string`	配信不能のソース。
`DeliveryCount`	`Int32`	配信回数。
`EnqueuedTimeUtc`	`DateTime`	エンキューされた時刻 (UTC)。
`ExpiresAtUtc`	`DateTime`	有効期限 (UTC)。
`Label`	`string`	アプリケーション固有のラベル。
`MessageId`	`string`	有効になっている場合に、重複するメッセージを識別するために Service Bus が使用できるユーザー定義の値
`MessageReceiver`	`MessageReceiver`	Service Bus メッセージ受信者。使用すると、メッセージの破棄、完了、または配信不能とすることができます。
`MessageSession`	`MessageSession`	セッションが有効なキューとトピック専用のメッセージ受信者。
`ReplyTo`	`string`	キューアドレスへの返信。
`SequenceNumber`	`long`	Service Bus によってメッセージに割り当てられる一意の番号。
`To`	`string`	送信先アドレス。
`UserProperties`	`IDictionary<string, object>`	送信者によって設定されたプロパティ。

これらのプロパティは ServiceBusReceivedMessage クラスのメンバーです。

プロパティ	タイプ	説明
`ApplicationProperties`	`ApplicationProperties`	送信者によって設定されたプロパティ。
`ContentType`	`string`	アプリケーション固有のロジックのために送信者と受信者が利用するコンテンツタイプ識別子。
`CorrelationId`	`string`	関連付け ID。
`DeliveryCount`	`Int32`	配信回数。
`EnqueuedTime`	`DateTime`	エンキューされた時刻 (UTC)。
`ScheduledEnqueueTimeUtc`	`DateTime`	スケジュールされたエンキュー時刻 (UTC)。
`ExpiresAt`	`DateTime`	有効期限 (UTC)。
`MessageId`	`string`	有効になっている場合に、重複するメッセージを識別するために Service Bus が使用できるユーザー定義の値
`ReplyTo`	`string`	キューアドレスへの返信。
`Subject`	`string`	`Label` メタデータプロパティの代わりに使用できるアプリケーション固有のラベル。
`To`	`string`	送信先アドレス。

次のステップ

Azure Functions から Azure Service Bus メッセージを送信する (出力バインド)

Azure Functions の Azure Service Bus トリガー

例

属性

デコレーター

注釈

構成

使用方法

接続

接続文字列

ID ベースの接続

ID にアクセス許可を付与する

有害メッセージ

PeekLock 動作

メッセージのメタデータ

次のステップ

その他のリソース