2017-02-10 8 views
1

Azure Stream AnalyticsとDocumentDBを統合して、出力シンクとして使用しようとしています。問題は、処理ジョブが実行されているときにDocDBで作成された文書がないことです。クエリをテストしようとしましたが、出力をストレージアカウントに反映しようとしました。すべての値を含むストレージにjsonファイルが作成されていますが、DocDBは空のままです。私は既存のコレクションに正しくdocumentDB出力を設定しなかったAzure Stream AnalyticsがDocumentDB出力シンクを供給していません

WITH Res1 AS (SELECT id, 
    concat(
    cast(datepart(yyyy,timestamp) as nvarchar(max)), 
    '-', 
    cast(datepart(mm,timestamp) as nvarchar(max)), 
    '-', 
    cast(datepart(dd,timestamp) as nvarchar(max))) date, temp, humidity, distance, timestamp 
FROM 
    iothub Timestamp By timestamp) 

Select * into docdboutput FROM Res1 
Select * into test FROM Res1 

は、ここに私のクエリです。私も提供しようとし、ドキュメントidパラメータを提供しないようにしましたが、どちらのオプションも機能していませんでした。私はDocDBデータベースとコレクションを作成するときに、パーティションキーとして日付フィールドを使用しました。

私はマニュアルドキュメントのアップロードも試みました。作成したjsonファイルの行をストレージアカウントにコピーしました。私はこの1つのレコードを含む別々のjsonファイルを作成し、ポータルを介して手動でDocumentDBコレクションにアップロードしました。それは成功した。ここでは、ストレージファイルに出力された1行の例です。

{"id":"8ace6228-a2e1-434d-a5f3-c2c2f15da309","date":"2017-2-10","temp":21.0,"humidity":20.0,"distance":0,"timestamp":"2017-02-10T20:47:54.3716407Z"} 

私のクエリに問題がある場合は、誰もが、私をアドバイスすることができますしてください、またはどのように私が調査することができ、さらに診断、私をナビゲートします。

答えて

2

万一、< = 10K RUsのコレクションを使用していて、DocDb(別名シングルパーティションコレクション)でパーティションキーが定義されていますか?

単一パーティション化されたコレクションへの出力をブロックしている進行中の欠陥があります。これは来週末までに修正する必要があります。 A)と> 10KのRU(DOCDB/ASAで定義されていないパーティションキーと< = 10KのRU(とDOCDBで定義されたパーティション・キー) B)との)

- この時点であなたの回避策は、別のコレクションを使用してみています

希望に役立ちます!

+0

ありがとうございました@Chetan、私は10k RU/sを上回りました。そして、私はクエリを実行した後に挿入された結果を見ることができます。しかし、ドキュメントエクスプローラには、データがデータベースに書き込まれたとはいえ、文書は表示されません。何が原因で起こりうるのか知っていますか? –

+1

@marek_lani:私は最近、DocumentDBと同じことを最近観察しました。私は、ドキュメントエクスプローラ経由ではなく、クエリ経由でドキュメントを見ることができます。それは、パーティション化されたコレクションの問題でしかないようです。パーティションにまたがるクエリは非常に高価ですが、これは設計によるものです。 –

関連する問題