イベントハブを使用して Azure Time Series Insights Gen1 環境にイベントを送信する

[アーティクル]
06/01/2023

注意

Time Series Insights (TSI) サービスは、2025 年 3 月以降はサポートされなくなります。できるだけ早く既存の TSI 環境を代替ソリューションに移行することを検討してください。サポートの終了と移行の詳細については、こちらのドキュメントを参照してください。

注意事項

これは Gen1 の記事です。

この記事では、Azure Event Hubs でイベントハブを作成して構成する方法について説明します。また、サンプルアプリケーションを実行し、Event Hubs から Azure Time Series Insights にイベントをプッシュする方法も説明します。 JSON 形式のイベントを含む既存のイベントハブがある場合は、このチュートリアルをスキップし、Azure Time Series Insights で環境を表示してください。

イベントハブを構成する

イベントハブを作成する方法については、Event Hubs のドキュメントをご覧ください。
検索ボックスで、Event Hubs を検索します。返された一覧で、 [Event Hubs] を選択します。
自分のイベントハブを選択します。
イベントハブを作成すると、イベントハブの名前空間が作成されます。名前空間内にまだイベントハブを作成していない場合は、メニューの [エンティティ] でイベントハブを作成します。
イベントハブを作成した後、イベントハブの一覧でそれを選択します。
メニューで、 [エンティティ] の [イベントハブ] を選択します。
イベントハブの名前を選択して構成します。
[概要] で [コンシューマーグループ] を選択し、 [コンシューマーグループ] を選択します。
Azure Time Series Insights のイベントソースで排他的に使用されるコンシューマーグループを作成していることを確認します。

重要

このコンシューマーグループがその他のサービス (Azure Stream Analytics ジョブや別の Azure Time Series Insights 環境など) で使用されていないことをご確認ください。コンシューマーグループが他のサービスで使用されている場合、この環境と他のサービスの両方で読み取り操作が悪影響を受けます。コンシューマーグループとして $Default を使用した場合、他の閲覧者がそのコンシューマーグループを再利用する可能性があります。
メニューで、 [設定] の [共有アクセスポリシー] を選択してから、 [追加] を選択します。
[新しい共有アクセスポリシーの追加] ウィンドウで、MySendPolicy という名前の共有アクセスポリシーを作成します。後で示す C# の例では、この共有アクセスポリシーを使用してイベントを送信します。
[要求] で、 [送信] チェックボックスをオンにします。

Azure Time Series Insights のインスタンスを追加する

Azure Time Series Insights Gen 2 では、Time Series Model (TSM) を使用して、受信テレメトリにコンテキストデータを追加できます。 TSM では、タグまたはシグナルは "インスタンス" と呼ばれており、"インスタンスフィールド" にコンテキストデータを格納できます。データはクエリ時にタイムシリーズ ID を使用して結合されます。この記事の後半で使用するサンプルの風力発電プロジェクトのタイムシリーズ ID は、です。インスタンスフィールドにデータを格納する方法の詳細については、タイムシリーズモデルの概要を参照してください。

Azure Time Series Insights のイベントソースを作成する

イベントソースを作成していない場合は、イベントソースを作成する手順を実行します。
timeSeriesId の値を設定します。 時系列 ID について詳しくは、「時系列モデル」をご覧ください。

風力発電のサンプルにイベントをプッシュする

検索バーで「Event Hubs」を検索します。返された一覧で、 [Event Hubs] を選択します。
自分のイベントハブインスタンスを選択します。
[共有アクセスポリシー][MySendPolicy] にアクセスします。 [接続文字列 - 主キー] の値をコピーします。
TSI Sample Wind Farm Pusher に移動します。このサイトでは、シミュレートされた風力発電デバイスが作成され、実行されます。
Web ページの [イベントハブ接続文字列] ボックスに、風力発電の入力フィールドでコピーした接続文字列を貼り付けます。
[Click to start](クリックして開始) を選択します。

ヒント

また、風力発電シミュレーターでは、Azure Time Series Insights GA クエリ API でペイロードとして使用できる JSON も作成されます。

Note

シミュレーターは、ブラウザーのタブが閉じられるまでデータを送信し続けます。
Azure portal でイベントハブに戻ります。 [概要] ページに、イベントハブによって受信された新しいイベントが表示されます。

サポートされている JSON 構造

例 1

入力:単純な JSON オブジェクト。

{
    "id":"device1",
    "timestamp":"2016-01-08T01:08:00Z"
}

出力:1 つのイベント。

id timestamp

device1 2016-01-08T01:08:00Z

id	timestamp
device1	2016-01-08T01:08:00Z

例 2

入力:2 つの JSON オブジェクトを含む JSON 配列。各 JSON オブジェクトがイベントに変換されます。

[
    {
        "id":"device1",
        "timestamp":"2016-01-08T01:08:00Z"
    },
    {
        "id":"device2",
        "timestamp":"2016-01-17T01:17:00Z"
    }
]

出力:2 つのイベント。

id timestamp

device1 2016-01-08T01:08:00Z

device2 2016-01-08T01:17:00Z

id	timestamp
device1	2016-01-08T01:08:00Z
device2	2016-01-08T01:17:00Z

例 3

入力:2 つの JSON オブジェクトを含む入れ子になった JSON 配列を含む JSON オブジェクト。

{
    "location":"WestUs",
    "events":[
        {
            "id":"device1",
            "timestamp":"2016-01-08T01:08:00Z"
        },
        {
            "id":"device2",
            "timestamp":"2016-01-17T01:17:00Z"
        }
    ]
}

出力:2 つのイベント。 location プロパティが各イベントにコピーされます。

location events.id events.timestamp

WestUs device1 2016-01-08T01:08:00Z

WestUs device2 2016-01-08T01:17:00Z

location	events.id	events.timestamp
WestUs	device1	2016-01-08T01:08:00Z
WestUs	device2	2016-01-08T01:17:00Z

例 4

入力:2 つの JSON オブジェクトを含む入れ子になった JSON 配列を含む JSON オブジェクト。この入力は、グローバルプロパティが複雑な JSON オブジェクトによって表現できることを示しています。

{
    "location":"WestUs",
    "manufacturer":{
        "name":"manufacturer1",
        "location":"EastUs"
    },
    "events":[
        {
            "id":"device1",
            "timestamp":"2016-01-08T01:08:00Z",
            "data":{
                "type":"pressure",
                "units":"psi",
                "value":108.09
            }
        },
        {
            "id":"device2",
            "timestamp":"2016-01-17T01:17:00Z",
            "data":{
                "type":"vibration",
                "units":"abs G",
                "value":217.09
            }
        }
    ]
}

出力:2 つのイベント。

location	manufacturer.name	manufacturer.location	events.id	events.timestamp	events.data.type	events.data.units	events.data.value
WestUs	manufacturer1	EastUs	device1	2016-01-08T01:08:00Z	pressure	psi	108.09
WestUs	manufacturer1	EastUs	device2	2016-01-08T01:17:00Z	vibration	abs G	217.09

次のステップ

Azure Time Series Insights エクスプローラーで自分の環境を表示します。
IoT Hub デバイスメッセージの詳細を参照してください。

イベント ハブを使用して Azure Time Series Insights Gen1 環境にイベントを送信する

イベント ハブを構成する