サーバレスAWSの非同期タスクキューLambda/Django/Zappa

Question

私は、DjangoアプリケーションをAWS LambdaにZappaでデプロイすることを実験しています。

私の他のいくつかの（EC2/EBSがホストする）Djangoプロジェクトでは、かなり時間がかかる重い計算を行う必要がある場合（電子メールをたくさん送信する、分）、Celeryが使用されます。これはタスクキューシステムであり、タスクはキューに送られ、応答はすぐに返され、後で作業者が処理することができます。

ラムダで実行されているZappa-Djangoアプリのためにセロリのようなタスクキューイングシステムを実装する最良の方法は何でしょうか？

ザッパ/ラムダは、スケジュールされたタスクをサポートし、アプリケーションのモデルは、処理は、後にスケジュール機能によって行うことができるとの結果がDBに保存することができように設計することができます。しかし、私は1分ごとにタスクのポーリングが十分に頑強だとは思っていません。遅延タスクをすぐに開始する必要が頻繁にあります。

後に実行されるようにキューに入れられた任意のパラメータで（Djangoのアプリ内からの）機能をすぐにDjangoのビューからの応答を返し、持ってする簡単な方法はありますか？

Answer 1

using SNSとすることができます。トピックにlambdaをサブスクライブし、そこにjsonペイロードでメッセージを公開してください。

Answer 2

私はzappaのdb駆動型タスクキューを作成しました。 https://github.com/andytwoods/zappa-call-later。初期段階では、生産中に使用しています。

すべてのX分、Zappaイベントは、タスクをチェックする関数をpingします。タスクを遅らせたり、繰り返したりすることができます。