問題タブ [task-queue]

いくつかのタスクをタスクキューに入れていますが、特定のタスクがいつ実行されるかを知りたいです。APIでコールバックやタスクのステータスの確認について何も見つからなかったので、他の人が何をしているのか、または回避策（または公式の）確認方法があるかどうかを確認したいと思いました。私は個々のタスクを気にしません。それが役立つ場合は、6つの異なるタスクを入れており、6つすべてがいつ完了したかを知りたいです。

ありがとう！

テストベッドを使用してGoogleAppEngineアプリの単体テストを行っていますが、アプリはタスクキューを使用しています。

単体テスト中にタスクをタスクキューに送信すると、タスクはキューにあるように見えますが、タスクは実行されません。

単体テスト中にタスクを実行するにはどうすればよいですか？

TaskQueue をバックエンドに渡すために次のことを試みましたが、うまくいきませんでした。

この構文に問題はありますか?

バックエンド.xml:

私は投票アプリに取り組んでいます。このアプリでは、ユーザーがすべての投票者のメールアドレスのリストをアップロードできます。エラーチェックを行った後、Voter投票者ごとにエンティティを作成します。多数の投票者がいる可能性があるVoterため、30秒の制限を回避するために、タスクキューにエンティティを作成します。タスクは次のようになります。

ただし、このタスクはべき等ではありません。このタスクをべき等にする方法はありますか？それとも、これを行うためのより良い方法はありますか？

バックグラウンドで実行したいアクションがいくつかありますが、それらは次々と同期的に実行する必要があります。

これを実現するために Task.ContinueWith メソッドを使用するのは良い考えかどうか疑問に思っていました。これに何か問題があると思いますか？

私のコードは次のようになります。

Google Task Queue Python API を使用して最初のコードを作成しました。アドレスバーに URL を入力するたびにメールが送信されるようになっています。ダッシュボードのタスク キューにタスクが表示されdefaultますが、開始してから 1 時間経っても実行されない理由がわかりません。

キュー-mail.py:-

app.yaml:-

コードを次のように呼び出しました。appid.appspot.com/mail

Google App Engine のタスク キューを使用しています。初めてです。チュートリアルを見つけましたが、いくつか問題があります。以下は、タスク キューをチェックするために使用している 2 つのサーブレットです。

2 番目のサーブレットは次のとおりです。

次の URL で GAEJCreateTaskServlet を呼び出しています。

今問題は、このURLを呼び出すと、タスクが作成されたという出力が表示されますが、開発コンソールではキューにタスクが表示されないことです。両方のサーブレットから doPost 関数を削除すると、キューにタスクが表示されますが、実行しても何も起こらず、タスクはそこに残ります。なぜそうなるのか、どうすればこの問題を解決できますか。前もって感謝します。

GAE TaskQueue の REST API を使用して、タスクをキューから外部サーバー (GAE にないサーバー) にプルしようとしています。

• 私のためにこれを行うライブラリはありますか？

• API は非常にシンプルなので、認証を理解するだけで済みます。usinggtaskqueue_sampleから送信されたリクエストを調べたところ、ヘッダーが見つかりました。そのトークンを自分の要求に追加することはできましたが、トークンは定期的に (おそらく毎日) 期限切れになるようで、再生成する方法がわかりません。さらに言えば、gtaskqueue_sample 自体が機能しなくなりました ( への呼び出しは で失敗します)。google-api-python-client--dump_requestauthorization: OAuth XXXhttps://accounts.google.com/o/oauth2/tokenNo JSON object could be decoded

認証はどのように処理しますか? これはサーバー アプリなので、理想的には、それ以降使用できるトークンを生成できます。

多くの異なるスレッドが割り当てを要求できる共有メモリ プールがあります。これから割り当てを要求すると、すべてのスレッドで大量に発生しますが、スレッドの量は少なく、多くの場合、実行中のスレッドは 1 つだけです。これを処理する次の方法のどれが優れているかわかりません。

最終的には両方を実装して、どちらがより好ましい結果をもたらすかを確認する必要があるかもしれません...また、この共有リソースを使用するコードを実際にはまだ作成していないため、この時点で #2 を考えても時期尚早の最適化になるのではないかと心配しています。しかし、この問題は非常に興味深いので、他の作業から気をそらし続けています。

1) ミューテックスを作成し、割り当てを取得する前にスレッドにロックを試行させ、ロックを解除します。

2) 各スレッドに要求スロットを登録させます。割り当てが必要な場合は、要求をスロットに入れ、(while (result == NULL) { usleep() }) 要求スロットが結果を待つのをブロックします。1 つのスレッドがリクエスト スロットを継続的に反復し、割り当てを行い、リクエスト スロット内の結果に割り当てます。

番号 1 は単純な解決策ですが、タイミングが適切であれば、1 つのスレッドがロックを独占する可能性があります。2 つ目はより複雑ですが、リソースからプルするときにスレッド間の公平性を保証します。ただし、要求元のスレッドは引き続きブロックされ、多数のスレッドが存在する場合、実行する要求が見つかるまで、実際の割り当てを行わずに反復がサイクルを焼き尽くす可能性があります。

注: pthread を使用する Linux 上の C

アップロードしている大きなファイルがあります。リクエスト全体で30秒以上かかる可能性があるため、タスクキューに移動しました。問題は、タスクでもこのエラーが発生することです。
これは、ファイルをアップロードする単一のリクエストであり、このため30秒の制限の影響を受けないためだと思います。「バックエンド」ソリューションを使用する以外に、この制限を回避する方法はありますか（App Engineはこれを追加したと思いますが、有料機能であり、少し複雑に見えます）？残念ながら、ファイルを分割することはできません。

編集：混乱してすみません。アップロードとは、外部サーバーにアップロードすることを意味します。シナリオは、データストアからデータを取得し、それをGoogleDocsSpreadsheetsにアップロードすることです。タスクキューにあるにもかかわらず、Googleドキュメントにアップロードする単一のリクエストが30秒を超えており、タイムアウトになっています。