azure-eventhub

1熱

1答えて

HDInsight Stormはサンプルアプリケーションを使用してEventHubsを読み書きできません

のサンプルEventHubアプリケーションを実装しようとしていますが、エラーが表示されます。私はこの文書で与えられた全く同じ手順に従った。私はHDInsight 3.5、Storm 1.0.1.2.5.4.0-121にあります。 Storm UIから見たEventHubReaderのものです。 com.microsoft.eventhubs.client.EventHubException: or

2熱

1答えて

EventHubのARMテンプレートからThroughPut単位を設定してください

私はアームテンプレートを介してEventHubのスループット単位を設定しようとしています。私はこれをする方法を見つけるように見えない。誰にもアイデアはありますか？スキーマを見ると

0熱

1答えて

AndroidからのAzureイベントハブの承認

私は紺碧のイベントハブにデータを送信するアプリケーションで作業しています。 http://sreesharp.com/send-events-from-android-app-to-microsoft-azure-event-hubs/ しかし、私はOkHttp使用する接続コードを更新：これはここにブログの記事に似て public void sendMessageOkHttp(String dat

0熱

1答えて

AzureイベントハブAMQP1.0送信者とSAStoken

現在、Azure Event Hubには、AMQP1.0クライアント（node.js）の情報を送信しようとしています。 SAStokenで認証する必要があります。次のようになり私はSASkeyとSASKeyNameを使用することはできません。 var uri = protocol + '://' + encodeURIComponent(sasName) + ':' + encodeURICo

1熱

1答えて

イベントハブUWP

私の問題へのメッセージを送信私はUWPを使用して、私のAzureのアカウントで作成したEventHubにテレメトリデータを送信する必要があります。私は、EventHubからデータを取得し、WebSocketを使用してリアルタイムグラフをプロットする、EventHub接続& Storage Areaキーに関する詳細を与えたWebアプリケーションを作成しました。私はEventHubにデータを送信す

0熱

1答えて

複数の共有アクセスポリシーをARMテンプレートに追加すると、1つしか作成されません。

ARMテンプレートを使用してイベントハブをデプロイしています。問題は、ARMテンプレートをデプロイすると定義されたいくつかのポリシーのうちの1つ（または2つ）が作成されるということです。残りは同じ方法で定義されていても作成されません。テンプレートを再配布すると、復元ポリシーの1つが追加されます。この原因は何ですか？

1熱

1答えて

Stream Analytics to Event Hub - 予期せずにイベントを連結する

私は、avroメッセージのイベントハブ（このRawEventsを呼び出す）を使用しているストリーム分析ジョブを使用して、メッセージを変形/平坦化して別のイベントハブこのFormattedEventsを呼び出します）。 RawEventsの各EventDataインスタンスは、より詳細なイベントの配列を持つ単一のトップレベルjsonオブジェクトで構成されています。これは不自然な例である： [{ "イベ

1熱

1答えて

スパークストリーミングとAzureイベントハブmapWithState

イベントハブからメッセージを引き出し、スパーク/スパークストリーミングで処理するコードを正常に統合しました。私は今メッセージが通過するときに管理状態に移っています。これは、ほとんどの部分はhttps://docs.cloud.databricks.com/docs/spark/1.6/examples/Streaming%20mapWithState.html 基本的に、これは、ダミーのソースで動

1熱

1答えて

Azureイベントハブではどのように異なるイベントが処理されますか？

異なるイベントタイプは、トピック/キューとメッセージヘッダーの組み合わせによって区別されます。カフカでは、記録ストリームは引き続きトピックとして分離されています（https://kafka.apache.org/intro）。 Azure Event Hubsのドキュメントを読むと、そのようなアイデアは出ていません。パーティションがありますが、これらはドキュメントに従って消費者の並列処理（http

0熱

2答えて

Blobストレージ入力はストリーム分析でnullを返します。ジョブ出力クエリ

私はAzureで初心者ですが、Windows AzureでStream Analyticsジョブを作成しました。ここでは、ジョブで2つの入力を使用しています.1つはイベントハブのタイプで、もう1つはタイプブロブストレージです。以下は（SQLデータベースに格納出力に）ASA仕事のためのSQLクエリです：以下 SELECT IP.DeviceId , IP.CaptureTime