膨大なセンサーデータと連携 ! Azure Cosmos DB 連携: 解説

2018-01-19

みなさん、こんにちは。

前回に続き、膨大なセンサーデータから自動で異常を検知して Dynamics 365 にケースを自動作成するサンプルデザインを紹介します。
前回の記事を読まれていない方は、是非ご覧ください。

膨大なセンサーデータと連携 ! Azure Cosmos DB 連携: 概要
 膨大なセンサーデータと連携 ! Azure Cosmos DB 連携: 事前準備その 1
膨大なセンサーデータと連携 ! Azure Cosmos DB 連携: 事前準備その 2

前回で、事前準備は完了しました。今回は、なぜこのようなデザインになっているのかを解説していきたいと思います。

概要

2 つのポイントを解説していきます。

- なぜコネクタ (Azure API) が必要なのか？
- 別の項目を連携するにはどうしたらよいか？

今一度サンプルデザインをご覧ください。

なぜコネクタ (Azure API) が必要なのか？

サンプルデザインをご覧になって、なぜコネクタ(Azure API) が必要なのかと疑問に思われた方もいらっしゃると思います。
理由は、Logic Apps にて Azure Cosmos DB のトリガーがないためと説明しましたが、一方、このコネクタは具体的に何をしているのか技術的な観点を解説します。

Azure Cosmos DB Document API

コネクタは、Logic Apps と Azure Cosmos DB の間にあり、Logic Apps のリクエストを Azure Cosmos DB に中継しています。
Azure Cosmos DB の API を利用するには、3 つの項目を HTTP ヘッダーに含める必要があります。

1. トークンのタイプ (type): トークンのタイプを指定します。（Master or resource）
2. トークンのバージョン (ver): トークンのバージョンを指定します。（現在は 1.0）
3. ハッシュされたトークン署名(sig): ここがポイントです。詳細は後ほど解説します。

実際にヘッダーに追加された例を示します。
type=master&ver=1.0&sig=5mDuQBYA0kb70WDJoTUzSBMTG3owkC0/cEN4fqa18/s=

ハッシュされたトークン署名

ハッシュされたトークン署名は、4つの情報をもとに生成します。

1. リクエストの種類（GET, POST or PUT）
2. 対象リソースの種類（"dbs", "colls", "docs"）
3. リソースのリンク（例: "dbs/MyDatabase/colls/MyCollection"）
4. リクエスト発行日時（例: Tue, 01 Nov 1994 08:12:31 GMT）

Azure Cosmos DB は、リクエストする日時ごとにハッシュされたトークン署名を生成してアクセスする必要があります。本サンプルデザインにおいて、この処理を実施しているのがまさしくコネクタになります。トークンについての詳細は以下を参照ください。

Constructing the hashed token signature for a master token:
https://docs.microsoft.com/ja-jp/rest/api/documentdb/access-control-on-documentdb-resources?redirectedfrom=MSDN#constructkeytoken

Connector of のソースコードの確認

では、コネクタのソースコードを実際にチェックしてみましょう。

1. コネクタの GitHub に行きます。

https://github.com/jeffhollan/docdb-connector

2. docdb-connector/controllers/document.ts を開きます。

3. document.ts には、5 つの API が定義が記載されいるのがわかります。

- POST - create a document
- POST - Upsert a document - called from a PUT /docs on client
- GET - get a document by index
- PUT - replace a document by index
- POST - query for documents - client calls via POST on /query/docs

4. 5 つ目の POST - query for documents を見てみます。getAuthorizationUsingMasterKey メソッドを呼び出してハッシュされたトークン署名を取得しています。