2017-09-11 13 views
0

私は、IoTデバイスがMQTTプロトコルを使って(メッセージをプッシュするために1つのトピックを使用して)、イベントをAzure IoTハブにパブリッシュするアプリケーションを開発しています。 Stream Analyticサービスを使用してこれらのメッセージを消費する必要があります。そして、ストリーム分析サービスをスケールするには、partitionBy節を使用することをお勧めします。Iot Hub AzureでpartitionIdまたはpartitionKeyを使用する

AzureイベントハブSDKを使用していないので、どういうわけかパーティションIDをイベントに添付できますか?リタはコメントで述べたようにアドバンス

+0

は何あなたのストリーム分析ジョブの出力になりますか? –

+0

結果をデータベースに保存します。 – Pragmatic

+0

その後、気にしないでください。 'Partition By'を使うことは、宛先が別のイベントハブのようにパーティショニングをサポートしているときだけ効果があります。 –

答えて

0

おかげで、イベント・ハブは、自動的に特定のパーティションに各デバイスを関連付けます。

次に、入力の処理を効率的に並列化し、データを縮小/集約するために、入力に近いステップでPartitionIdを使用することができます。 次に、パーティション化されていない別のステップをいくつか集約データを送信するSQLに出力することができます。

これを行うと、SQLへの出力であっても、6 SUにさらに感謝することができます。

ASAジョブのスケーリングに関する詳細情報を提供し、さまざまなシナリオについて説明します。

おかげで、

JS - Azureのストリーム解析

関連する問題