問題タブ [pull-queue]

dev_appserver を使用してローカルでアプリケーションを実行しているときに、プル キューからタスクをリースする方法はありますか?

より詳しい情報：

プル キューを使用する GAE アプリがあります。Java で記述された別のサービスから、そのキューからタスクをリースする必要があります。マシンで dev_appserver を使用して GAE アプリを実行しています。このキューからタスクをリースするにはどうすればよいですか? GAE のドキュメントには、 https://www.googleapis.com/taskqueue/v1beta1/projects/taskqueuesの REST エンドポイントにアクセスしてタスクをリースする必要があると記載されています。この URI は私のマシンでは公開されていません。

アプリのメッセージキューとしてGAE Task Queue（ ）を使用したいのですが。他のメッセージキューサービス（例）pull queueの呼び出しは非同期呼び出しであり、アプリにWebスケーラビリティを提供します。receiveMessageAmazonSQS

代わりに、このpull queue呼び出しが非同期であるかどうかを知りたいのです。アプリにWebスケーラビリティを提供する必要があるからです。leaseTaskreceiveMessage

ありがとう

私のプロジェクトは GAE/J に基づいており、最近リリースされた PULL キューを利用していますが、この質問は Python にも適用できると思います。

基本的に、タスクを PULL キューに入れるときは、後のコンシューマーがそれを取得できるように、タスクのいくつかのパラメーターを設定する必要があります。

私は両方の方法で params 設定に実装しました:

1) を使用してparam():

2) を使用してpayload():

どちらのアプローチも機能していますが、私が知りたいのは、この 2 つの違いと、効率や利便性の観点からどちらの方法が望ましいかです。

を使用するparam()と、複数のパラメーターを簡単に設定でき、コンシューマーのパラメーターを簡単に取得できることがわかります。ただし、パラメーターが 1 つの場合、ペイロードは、コンシューマーがパラメーターを抽出するときにスローされる例外をキャッチするコードを保存するため、より便利になる場合があります。

ただし、私が言及したこととは別に、これら2つの違いをさらに知りたいと思います.

私のアプリは Java で実行されていますが、これは Python にも当てはまるはずです。

基本的に私が達成したいのは、キュー内の既存のタスクを変更できるようにすることです。

すべてのタスクは特定の名前でタグ付けされ、どのプロバイダーがそれを使用するかを決定します。ただし、場合によっては、1 つのタグのプロバイダーがダウンしている可能性があります。この場合、他のプロバイダーがこれらの長い待機タスクを取得できるようにする必要があります。

これを行うために、特定のプロバイダーがサーバーからしばらくポーリングしていない場合 (事前に定義されたしきい値)、サーバーがキューに入り、タスクのタグを別のものに変更する方法について考えました。他のプロバイダーがそれを消費できるようにします。

しかし、ドキュメントから、これを行う方法を見つけることができないと思います。

誰かがヒントを与えることができますか、またはこの問題を解決する他の方法がありますか?

タスクがタスク キューからフェッチされるまでの最小時間を設定できますか? X日後にタスクを処理したいです例えば、簡単な方法はありますか、またはこの情報をタスク自体に入れる必要がありますか? ほとんどのタスクを 3 日間で実行する必要がある場合、2 時間ごとにすべてのタスクをロードするのは非効率に思えます (例: cron ジョブを使用)。

Java (Google API) でプル キューを読み込もうとしています。

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

そして私の輸入品：

コードに 2 つのエラーがあります: メソッド

useMethodOverride

と

デフォルトヘッダー

存在しないので、ここのドキュメントからこのコードを取得しました: https://developers.google.com/appengine/docs/java/taskqueue/overview-pull

Google サンプル コード - Taskqueue-cmdline-sample を使用して、Google Queue API への認証を試みます。

サンプルの client_secrets.json ファイルに、Google クライアント ID と Google クライアント シークレットを設定する必要があります。

したがって、私の問題は、そこで使用する資格情報とそれらを取得する方法です! さらに、クライアント ID ではなく、GAE の queue.xml の ACL で電子メール アドレスを使用する必要があります...

ドキュメントに、クライアント ID/シークレットを取得するためのリンクがあります: http://code.google.com/p/google-api-java-client/source/browse/shared/shared-sample-cmdline/ src/main/java/com/google/api/services/samples/shared/cmdline/oauth2/OAuth2Native.java?repo=サンプル

しかし、それは死んでいます... (404) --> FIXED

ドキュメント: http://samples.google-api-java-client.googlecode.com/hg/taskqueue-cmdline-sample/instructions.html

サンプルをチェックアウトしてください: http://code.google.com/p/google-api-java-client/source/checkout

アップデート

TaskQueue API がサービスの一覧にありません。TaskQueue API を有効にするにはどうすればよいですか?

サンプルを機能させようとしているので、コードは次のとおりです。

サンプルコード

インストールのドキュメントは次の場所にあります。

インストール ドキュメント

ステップで少し問題がありました：

[API アクセス] をクリックし、[OAuth 2.0 クライアント ID を作成...] をクリックします。商品名を入力して「次へ」をクリック。

コンソールの UI はおそらくアップグレードされているので、コンソールでの認証にこれらのデータを使用します。

次に、プログラムを実行すると、アプリを許可する Web ページが表示され、コンソールに次のエラー メッセージが表示されます。

私の queue.xml ACL は、認証に使用した電子メールで設定されています

キューが本当に空かどうかについて混乱しています。このビューから、「squid-pri-0」と呼ばれるキューは、キューに 14 個のタスクがあることを示しています。

しかし、それをクリックすると、空だと表示されます（以下を参照）。ただし、空白ではない「古いタスク」も表示され、実際には空白ではないと思います。どの数字/統計を信じるべきですか?

Python を使用してコンピューティング OAuth トークンを使用して Google コンピューティングからプル キューにアクセスしようとしています。

HttpError 403「この API 呼び出しを行うことは許可されていません」が発生し続けます

助けてください、どの設定が欠けていますか?

ありがとう、シェイ