Azure Stream Analytics からの Service Bus キュー出力

  • [アーティクル]

Service Bus キューでは、競合している 1 つ以上のコンシューマーへのメッセージ配信に FIFO が使用されます。 通常、メッセージはキューに追加された時間的順序で受信者によって受信され、処理されます。 各メッセージを受信し、処理するメッセージ コンシューマーは 1 つのみです。

互換性レベル 1.2 では、Azure Stream Analytics は Advanced Message Queuing Protocol (AMQP) メッセージング プロトコルを使用して Service Bus キューおよびトピックに書き込みます。 AMQP を使用すると、オープンな標準プロトコルを使用したクロス プラットフォームのハイブリッド アプリケーションをビルドできます。

出力の構成

次の表に、キューの出力を作成するためのプロパティの名前とその説明を示します。

プロパティ名 説明
出力エイリアス クエリの出力をこの Service Bus キューに出力するためにクエリ内で使用されるフレンドリ名です。
Service Bus 名前空間 一連のメッセージング エンティティのコンテナーです。
キュー名 Service Bus キューの名前です。
キュー ポリシー名 キューを作成するとき、キューの [構成] タブで共有アクセス ポリシーを作成することもできます。各共有アクセス ポリシーには、名前、設定したアクセス許可、アクセス キーが含まれています。
キュー ポリシー キー Service Bus 名前空間へのアクセスを認証するために使用する共有アクセス キー。
イベントのシリアル化の形式 出力データのシリアル化形式です。 JSON、CSV、Avro がサポートされています。
エンコード CSV と JSON では、現在のところ、UTF-8 が唯一サポートされているエンコード形式です。
区切り記号 CSV のシリアル化のみに適用されます。 Stream Analytics は、CSV 形式のデータをシリアル化するために、一般的な区切り記号をサポートしています。 サポートしている値は、コンマ、セミコロン、スペース、タブ、および縦棒です。
Format JSON 型のみに適用されます。 [改行区切り] を指定すると、各 JSON オブジェクトを改行で区切って、出力が書式設定されます。 [改行区切り] を選択した場合、JSON は一度に 1 オブジェクトずつ読み取られます。 コンテンツ全体は、それ自体では有効な JSON になりません。 [配列] を指定すると、JSON オブジェクトの配列として出力が書式設定されます。
プロパティ列 省略可能。 ペイロードではなく、送信メッセージのユーザー プロパティとして関連付ける必要があるコンマ区切りの列です。 この機能の詳細は、「出力用のカスタム メタデータ プロパティ」セクションにあります。
システム プロパティ列 省略可能。 ペイロードではなく送信メッセージに添付する必要がある、システムプロパティと対応する列名のキーと値のペア。

パーティション数は、Service Bus SKU とサイズに基づいています。 パーティション キーは、各パーティションに固有の整数値です。

パーティション分割

パーティション分割が自動的に選択されます。 パーティション数は、Service Bus SKU とサイズに基づいています。 パーティション キーは、各パーティションに固有の整数値です。 出力ライターの数は、出力キュー内のパーティションの数と同じです。

出力バッチ サイズ

メッセージの最大サイズは、Standard レベルではメッセージあたり 256 KB、Premium レベルでは 1 MB です。 詳細については、Service Bus の制限に関する記事を参照してください。 最適化するには、メッセージごとに 1 つのイベントを使用します。

出力用のカスタム メタデータ プロパティ

ご自分の送信メッセージにクエリ列をユーザー プロパティとして添付できます。 これらの列はペイロードに入りません。 これらのプロパティは、出力メッセージにディクショナリの形式で表示されます。 "キー" は列名で、"値" はプロパティ ディクショナリの列値です。 Record と Array を除き、すべての Stream Analytics データ型がサポートされています。

次の例では、DeviceId フィールドと DeviceStatus フィールドがメタデータに追加されています。

  1. 次のクエリを使用します。

    select *, DeviceId, DeviceStatus from iotHubInput

  2. 出力のプロパティ列として DeviceId,DeviceStatus を構成します。

    Property columns

次に示すのは、Service Bus Explorer を利用して EventHub で検査される出力メッセージ プロパティの図です。

Event custom properties

システム プロパティ

クエリ列を、システム プロパティとして送信 Service Bus キューまたはトピック メッセージに添付できます。

これらの列はペイロードに含まれず、代わりに対応する ServiceBusMessage システム プロパティには、クエリ列の値が設定されます。 システムプロパティ (MessageId, ContentType, Label, PartitionKey, ReplyTo, SessionId, CorrelationId, To, ForcePersistence, TimeToLive, ScheduledEnqueueTimeUtc) はサポートされています。

これらの列の文字列値は、対応するシステム プロパティ値の型として解析され、解析エラーはデータ エラーとして扱われます。 このフィールドは、JSON オブジェクト形式で提供されます。 この形式の詳細は次のとおりです。

  • 中かっこ {} で囲まれている。
  • キーと値のペアで記述されている。
  • キーと値は文字列である必要がある。
  • キーはシステム プロパティの名前、値はクエリ列の名前となっている。
  • キーと値は、コロンで区切って指定されている。
  • キーと値のペアはそれぞれ、コンマで区切られている。

このプロパティの使用方法を次に示します。

  • クエリ: select *, column1, column2 INTO queueOutput FROM iotHubInput
  • システム プロパティ列: { "MessageId": "column1", "PartitionKey": "column2"}

これにより、column1 の値を持つ Service Bus キューメッセージに MessageId が設定され、PartitionKey が column2 の値で設定されます。

次のステップ