GAE Task Queue をマイクロサービスのサービス間通信として使う - addsict's blog
昨今マイクロサービスアーキテクチャに基づいたアプリケーション構築が話題ですが、Google App Engine を用いてる場合 Task Queue をサービス間の通信として便利に使用することが出来ます。 GAE の Task Queue (Push) について 背景 マイクロサービスでよくやることとして、あるサービスでイベントが発生したらそれを別のサービスに非同期に通知したいことがあります。 通常のアプリケーションの場合、何かしらの Message Queue を用いて Job Worker 経由で別のサービスに通知することが多いと思います。 +-----------+ | Service A | +-----------+ ↓ Push +-----------+ | MQ | +-----------+ ↑ Pull +-----------+ | Job Worker| +---
GAEで時間のかかる処理を分割する方法（タスクキューの使い方） | TechBooster
GoogleAppEngineでは、時間のかかる処理を分割して平行実行するためにTaskQueue(タスクキュー)機能が用意されています。今回はタスクキューを利用した並列化を紹介します。 他のWebサービスとの連携など負荷制御が必要なケースや、実行時まで処理時間がわからないタスクのために利用すると良いでしょう。 たとえばTwitterへのtweet投稿などでは連続動作させると意図せず、相手サーバーへのDoS攻撃になってしまいます。また登録されているメールアドレス全てにメールを送信する、など データベースの登録状況に依存する処理の場合、だんだんと処理時間が伸びてしまうため並列化が必要になります。 タスクキューを利用する方法はとても簡単です。サンプルコードは続きから。 Queueを定義する タスクキューに登録するQueueは、queue.xmlで実行間隔を制御できます。queue.xmlを作り
App Engine のリソース管理 - TaskQueue の設定 - Kay's daddy
TaskQueue の設定を変更する TaskQueue をデフォルトの設定で使っていると、いくつかまとめて Task を登録した時に並列処理が走り、Frontend Instance が複数立ち上がってしまいます。そこで、max_concurrent_requests を設定することで、同時に実行される Task の数を制限できます。下記の yaml ファイルでは、“default” Queue の max_concurrent_requests を 1 に設定しています。 queue.yaml queue: - name: default rate: 5/s max_concurrent_requests: 1 もちろん、この設定によって Task の実行が遅くなりますが、インスタンスの数は抑えられるはずです。 9/8 追記: また、Task を追加するときに X-AppEngine-
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
https://blog.sojiro.me/blog/2016/08/10/about-gae-task-queue
