2016-03-21 11 views
0

Blobストレージを入力(JSONファイル)として使用しています。私はクエリをテストしましたが、クエリは正常に見えます。 Azure SQL Server TableとしてOutputを指定しました。 SSMSからこのデータベースに接続してテーブルを照会することができます。Azure Stream Analyticsジョブに入力または出力がありません

ジョブのステータスは実行中ですが、SQLテーブルにデータがロードされていません。 Azure Management Servicesの状態が「実行中」にエラーがないことを確認しました。何が起こっているのかを私はどのように診断するのですか?

注:Blobストレージパスの接頭辞は空のままです。私はストレージコンテナに入っていて、いくつかの特定のファイルではないファイルを取得したいと思います。

+0

pathPattern "path prefix"は不要なので、空白にしても効果はありません。あなたはクエリを投稿できますか? – tripdubroot

+1

以前のコメントが削除されたため、ASA *はBLOBに格納されたイベントの処理を許可します。しかし、ETLツールではありません。ファイル形式に問題がある可能性があります。代表的なサンプルでクエリをテストしましたか?成功したテストファイルをコンテナにアップロードすると、クエリは機能しますか? 2番目の出力を別のBLOBコンテナに追加し、2番目のクエリ 'SELECT * INTO OUTPUT2 ... 'を追加して、問題が* input *でないことを確認してください。データが表示されない場合は、入力に問題があります。存在する場合、問題はクエリにあります –

答えて

0

クエリを作成しましたか?最初にクエリを作成し、ストリーム分析を開始する必要があります。

クエリ例:

SELECT 
    * 
INTO 
    Output 
FROM 
    Input 
+1

私はクエリを作成し、テストしました。それはうまく動作します。 Stream Analyticsジョブを停止してから、BlobストレージにファイルをアップロードしてからStream Analyticsジョブを再開すると、それらのファイルをストリーミング/ロードしないことに気付きました。ただし、Stream Analyticsジョブの実行中にファイルをアップロードすると、正常にAzure SQLテーブルにロードされます。ストリーム解析ジョブが実行されていないときに新しいファイルがBlobストレージにアップロードされたとき、次回新しいファイルをロードするときに新しいファイルがBlobストレージにアップロードされるように、この動作を変更する方法はわかりますか? – greypanda

+1

ストリームアナリティクスの目的は、データのストリームを処理することです。既に適切な場所にあるときに処理したい場合は、スケジュールされたWebJobを検討することができます!あなたが解決しようとしている問題を知っていると良いでしょう。 – wuerzelchen

+0

@wuerzelchen ASA *は参照データだけでなく、BLOBをイベント入力としてサポートします。例えば、データがAPIゲートウェイ、バッチ処理、またはスケジュール処理から来た場合、これは変わったものではありません。 –

0

またPowerBIへの出力を作成し、SAを実行することができます。これは、データスキーマとクエリが正しいかどうかを示します。すべてがうまくいくならば、名前値がリストされたJSONファイルをデータセットとして見ることができます。受信したアイテムの数だけミニダッシュボードを作成して、BLOBからJSONをロードして処理するかどうかをリアルタイムで確認できます。

これが失敗すると、PBi出力への操作ログで、データスキーマがサポートされていないことが通知されます。

希望すると便利です。 Mert

関連する問題