問題タブ [azure-storage-queues]

複数のコンシューマがあり、複数のマシンで実行され、Azure ストレージ キューから読み取られます。最初のコンシューマーがキューから最初のメッセージを読み取り、それを 5 分間非表示にした場合、2 番目のコンシューマーはキューから次のメッセージを読み取るか、それともブロックされますか?

Azure Storage のクラウド キューにメッセージを送信しようとすると、次の例外がランダムに発生します。Android 用の Azure ストレージ クライアント ライブラリのバージョン 0.5.1 を使用しています。SAS を使用していません。代わりに、Azure アカウント名とキーを使用しています。この問題の解決を手伝ってください。

com.microsoft.azure.storage.StorageException: サーバーは要求を認証できませんでした。Authorization ヘッダーの値が、署名を含めて正しく形成されていることを確認してください。com.microsoft.azure.storage.core.StorageRequest.materializeException (StorageRequest.java:307) で com.microsoft.azure.storage.core.ExecutionEngine.executeWithRetry (ExecutionEngine.java:181) で com.microsoft.azure.storage .queue.CloudQueue.exists(CloudQueue.java:887) at com.microsoft.azure.storage.queue.CloudQueue.createIfNotExists(CloudQueue.java:526) at com.microsoft.azure.storage.queue.CloudQueue.createIfNotExists(CloudQueue) .java:501)

編集: これが例外の原因となった私のコードです。時々うまくいくと言ったように、例外はランダムに発生します。

分離された 2 つのアプリケーション間で通信する Azure Queue Storage を評価しています。

私の要件は、キュー メッセージでファイル (フラット ファイル、サイズ: 小から大) を送信することです。

私の読みによると、キュー内の個々のメッセージは 64KB を超えることはできないため、メッセージで可変サイズのファイルを送信することは問題外です。

私が考えることができる別の解決策は、キュー ストレージとブロブ ストレージの組み合わせを使用することです。つまり、キュー メッセージでファイルへの参照を追加し (ブロブ ストレージ上)、必要に応じてブロブからファイルを読み取ります (参照/アドレスを使用)。キュー メッセージ)。

私の質問は、これは正しいアプローチですか? または、これを達成するための他のエレガントな方法はありますか?

ありがとう、サンディープ

パフォーマンスの高い方法で Azure Queue Storage に書き込むための適切な呼び出し/コード パターンは何ですか?

現在、擬似コードは

StorageCredentials および CloudStorage アカウント プロパティを使用して静的クラスを作成します。アプリケーションの起動時に、設定ファイルから値を {get;} のみのプロパティに読み込みます。

アプリケーション メッセージ タイプの入力パラメーターを使用して、非同期 Task メソッドでクラスを作成します。このメソッドは型をシリアル化し、新しい CloudQueueMessage、新しい CloudQueueClient、新しい CloudQueue 参照を作成します。構成情報が必要な場合は、静的クラスから読み取られます。私のコード：

コードに冗長性があるように見えますが、接続がキューにプールされるかどうか/どのようにプールされるか、データベース (SQL Server など) 接続の場合と同様に再試行ロジックが必要かどうかもわかりません。

どのキュー アクセス手順を何らかの方法で削減または最適化できるかを理解しようとしています。

すべてのアイデアに感謝します。

.NET 4.5.2、C# を使用。コードはクラウド サービス (ワーカー ロール) で実行されています。

ありがとう。

キューからのメッセージを処理するために Azure Webjobs を使用しています。

Webjobs SDK は、失敗したメッセージを 10 分後に再度処理し、5 回失敗した場合はポイズン キュー ( 1 ) に移動することを確認しました。

また、キュー内のメッセージの nextVisibleTime も確認できます。これは、insertionTime ( 2 ) の 10 分後です。

メッセージの AzureSDK エラー処理を使用したいのですが、メッセージが再度処理されるまで 10 分待つことができません。

この nextVisibleTime を数秒に設定する方法はありますか?

Azure App Service で .NET WebJob を作成する

メソッドが完了する前に失敗した場合、キュー メッセージは削除されません。10 分間のリースが期限切れになると、メッセージは解放され、再び取得されて処理されます。

WebJobs SDK で Azure キュー ストレージを使用する方法

注: StackOverflow にも同様の質問がありますが、回答はありません。

• QueueTrigger 属性の可視性タイムアウト
• Azure WebJob QueueTrigger 再試行ポリシー

シナリオ: プロデューサーがストレージ キューにメッセージを送信し、Web ジョブが QueueTrigger でメッセージを処理します。各メッセージは 1 回だけ処理する必要があり、複数の Web ジョブ インスタンスが存在する可能性があります。

私はグーグルで調べてきましたが、読んだことから、メッセージが2回処理されないように、メッセージを処理する関数をべき等にする必要があります。また、メッセージのデフォルトのリース時間は 10 分であることも読みました。

私の質問は、ある WebJob インスタンスで QueueTrigger がトリガーされたときに、別の WebJob が同じメッセージを取得できないように、メッセージにリース時間を設定しますか? もしそうなら、メッセージが 2 回処理される可能性を考慮する必要があるのはなぜですか? それとも私はこれを誤解していますか？

Azure で WebApp を実行しています。WebApp の目的は、Azure ストレージ キューからのジョブを処理することです。常にオンに設定されています。問題は、Azure 管理ポータルで WebApp を停止しても、ジョブが実際に停止しないことです。

次のようにジョブをインスタンス化しました。

キューを処理する関数は次のとおりです。

トレース ログがあるので、ジョブが実際に停止することはありません。

ファイルを Azure Storage Container に送信し、その後 Azure Queue にメッセージを送信するアプリケーションを実行しています。

約1000~1020メッセージに到達すると、それ以上ファイルやメッセージを送信できなくなります。キューにあるメッセージの数を確認しようとすると、エラーが発生することにも気付きました。

エラーは次のとおりです。

私のコードは次のとおりです。

メッセージを送信する関数は次のとおりです。

私はここで本当に迷っています。ありがとうございました。