azure-eventhub

0熱

1答えて

Cloudera VMでspark2-submitを使用してScala jarファイルを実行中にUnsupportedClassVersionErrorを取得する

単一ノードでローカルにインストールされたCloudera VMにAzureイベントハブを含むScalaプロジェクトfrom hereを実行しようとしています。私はCDH 5.10を使用しています。 Openjdk 1.8.0を使用するsbt 0.13.15を使用してjarファイルを作成しました。 jarファイルを実行している間にspark2によって使用されているOracle Jdk 1.8も私のV

1熱

1答えて

イベントハブの入力サイズデータが、ストリーム解析を使用して読み取るときに出力サイズが3倍多くなる

イベントハブで100 KBのデータファイルを取り込むとき、ファイル。私は同じ問題を持っていたし、入力数（バイトとサイズによるが）パーティション係数を乗じた、ことを調査していたとして

0熱

2答えて

Azure Eventhubsを使用しているときにペイロードのサイズを確認し、PayloadSizeExceededExceptionを回避するにはどうすればよいですか？

だから私はこの例外を取得しています： com.microsoft.azure.servicebus.PayloadSizeExceededException: Size of the payload exceeded Maximum message size: 256 kb 私はそれについて何をすべきかが、私はわからない、例外は自明であると考えています。 private int MAXBYTE

0熱

1答えて

azureイベントハブに対してqpid陽子でフィルタを適用する方法

azure eventhubsに対してqpid-proton-0.17.0のフィルタを適用しようとしています。ここに私のフィルタコードです： proton::value filter_value; proton::codec::encoder enc(filter_value); enc << proton::codec::start::described() << proton::

0熱

1答えて

ストリームアナライザを使用せずにC＃を使用してイベントハブからData Lakeストアへイベントを書きたい

ストリームアナライザを使用せずにC＃を使用してイベントハブからイベントレイクストアにイベントを書きたいとします。 BLOBに書き込むことができますが、どのようにデータレーキに書き込むことができます。

0熱

1答えて

Azure POSと気象データ解析の戦略

私はAzureのソリューションのアプローチについて質問します。どの技術をどのように使用するか、そしてそれらの最良の組み合わせを見つける方法を決定する方法が問題です。のは、私は毎日成長している2つのデータセットを、持っているとしましょう：私は私のADLの店に毎日来て、それはすべての可能なLattitudesとLongtitudesの組み合わせとジッパーのための気象データを含むCSVファイルを持っ

0熱

1答えて

Microsoftからトークンを取得するサービスバストークンプロバイダ

利用可能なすべてのリソースとドキュメントを調べましたが、のアクションがのアクションがトークンプロバイダで意味するものを把握できませんでした。渡す必要がある特定の文字列定数がありますか？ Reference to the method in docs.microsoft.com

2熱

2答えて

プログラムによるイベントハブコンシューマーグループのクエリ

.NET SDKを使用して、Azureイベントハブでコンシューマーグループを照会および作成する方法を知っている人はいませんか。私は負荷を探知して、REST APIを通してしか方法を見つけることができません（私はこれを行うことができますが、SDKを通じてそれを行うことができれば良いでしょう）。事前におかげ