問題タブ [task-queue]

サーブレットで行ったアプリを移行しようとしています。私は今Springを設定しました。問題は、キューに入れられたタスクが動作を停止したことです。countdownMillisメソッドを使用して、タスク プロパティで設定された時間待機していません。タスクは待機なしで実行されています。

何か案が？

ありがとう。

GAE用のアプリを開発していて、タスクキューを使用しようとしています。現在、GAE App Launcherを介してWindowsボックスで実行しているものがありますが、何かをキューに入れようとすると、開発用の「サーバー」がクラッシュし、ログが厄介な出力でいっぱいになります。

他の作業とのトランザクションでこれを実行しようとしたので、作業が正常にキューに入れられていると確信しています。

ただし、その後すぐに開発サーバーがクラッシュし、ログは次のようなものでいっぱいになります。

謝罪-以下の返信でタイプミスが見つかりました（TrueではなくTrue）。しかし、元の問題を解決しようとすると、これは忍び寄りました。タイプミスを修正すると、キューに入れられた作業は完了しますが、サーバーはログに次のエラーでフォールオーバーします。

taskqueue.addの呼び出しを削除すると、正常に機能します（もちろん、キューに入れられた作業はありません）。何が問題になっていますか？

私は最初の GAE アプリケーションをビルドしてデバッグしようとしていますが、Stackoverflowers の素晴らしいサポートの恩恵を受けて、デフォルト キューでタスクを処理することで、現在の状況を把握しています。ありがとう！

ただし、キューを使用して、バックグラウンドで「長い」作業を行う方法を示したかったのです。私の考えは：

1. 大きなファイルを処理する要求を受け取ります。
2. ファイルを保存し、タスクをキューに入れます。
3. 応答を返します。
4. バックグラウンドでファイルを処理します。
5. チャネルを介して、作業が完了したことをクライアントに知らせます。

私はこれをすべて機能させていますが、1つの問題があります。私の開発サーバーでは、タスク キューがバックグラウンドでタスクを処理していないようです。長時間実行される作業をシミュレートするために、そこにスリープを入れました。

GAE 開発サーバーはシングル スレッドのようです。アイテムがキューから処理されるまで、まったく応答しませんか? この仮定は正しいですか？何か案は？

ありがとう

コード例の追加:

Amazon SQS を使用してタスク キューを実装しています (ただし、質問はどのタスク キューにも当てはまると思います)。ここで、ワーカーは、ジョブが既に再試行された回数に応じて異なるアクションを実行することが期待されます (に移動します)。別のキュー、可視性タイムアウトの増加、アラートの送信など)

失敗したジョブ数を追跡する最良の方法は何ですか? job:retry-count レコード用に一元化されたデータベースを保持する必要がないようにしたいと思います。監視プロセスではなく、キューで費やされた時間を確認する必要がありますか? せいぜい醜い、または汚れているIMOで、古いジョブが見つかるまでジョブを繰り返します..

ありがとう！アンドラス

EMPLOYEEなどの単一のエンティティで約28,000の「行」を保持しようとしています

基本的に、私の目標は、30 秒を超える PUT を使用して終了/タイムアウトを回避することです。これは、サーブレットに送信された doPost() 要求を呼び出して 28,000 PUT を実行した場合に発生する可能性があることです。

そこで、Google App Engine のドキュメントに記載されているタスクを使用することを考えています。

基本的に、28,000 人の「従業員」を含む war ディレクトリに csv ファイルをアップロードしたいと考えています。次に、これらの 28,000 の従業員行を EMPLOYEE エンティティに非同期 PUT するタスクを作成します。

• Q1: これは実行可能な解決策ですか、それとももっと良い方法がありますか? 繰り返しますが、目標は PUT を実行して、30 秒の制限による終了を回避することです。

• Q2: また、これらの PUT をできるだけ速く実行できるようにするには、どの queue.xml 構成を使用すればよいですか?

• Q3: 今、ブログ エントリと同様に試してみました: http://gaejexperiments.wordpress.com/2009/11/24/episode-10-using-the-task-queue-service/しかし、私は取得しています23 秒ほど後に次のエラーが表示されます。

  /li>

• Q4: http://localhost:8888/_ah/adminで Datastore Viewer も確認しましたが、そのエンティティには 1000 件の結果しか作成されていないようです。1000枚が限界？

• Q5: 上記のエラーを取り除くにはどうすればよいですか?

• Q6: タスクの最大許容時間が 10 分であることを確認できますか? それともまだ30秒ですか？私はこれに出くわしました：http://code.google.com/appengine/docs/java/taskqueue/overview.html#Task_Execution

私はグーグルアプリエンジンで上記を達成しようとしています、そして誰かがこれがすでに行われているプロジェクトを知っているかどうか疑問に思っていましたか？または例？

これまでのところ、私の実装では、単一のオブジェクトをメモリに書き込むことができます。ただし、add_multiを使用して複数のオブジェクトを入力する際に​​問題が発生します。

助けてくれてありがとう。

このような問題に対処したいと思います。送信メールを送信するHTMLフォーム（登録フォームなど）があります。今、私はそれをページリクエストの一部として送信します。明らかな欠点：

• リクエストを長くします
• SMTPサーバーがダウンしたり、タイムアウトや電子メールが送信されない場合があります

PHPを使用するときは、キューに基づくソリューションを使用しました。オブジェクト/ xmlをキューホストに配置していたので、ある種のクライアントがそのキューをチェックしました。キュータスクが正常に処理された場合、キューからタスクが削除されました。Windows / .NETプラットフォームにも同様の実装がありますか？

ありがとう、Paweł

AppEngine TaskQueue サービスから呼び出される HTTP POST 本文のエンコーディングは何ですか?

経由でタスクを作成した場合TaskOptions#payload(byte[], String)、HTTP リクエスト本文のエンコーディングはどうなりますか?

同様に、String作成された viaTaskOptions#param(String, byte[])と取得された via のエンコーディングはどうなりますServletRequest#getParameter(String)か?

更新:使用する必要がある文字セット名は何ですか

経由で送信したバイナリ データを取得するにはTaskOptions#param(String, byte[])?

http://www.w3.org/TR/html4/interact/forms.htmlの「application/x-www-form-urlencoded」の定義で定義されていないサーブレットコンテナ固有のデフォルト値のようです#h-17.13.4.1 -- すべてがサーブレット API ですでに抽象化されているためです。