問題タブ [python-pika]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
python - http マイクロサービス内にバックグラウンド ジョブを実装する
いくつかのエンドポイントを公開するマイクロサービス (Python で記述) があり、これらの各エンドポイントは http 要求 (フラスコ) によって実行できます。
完了するまでに時間がかかる特定のエンドポイントが 1 つあるため、応答時間を短縮するために、このエントリポイントがトリガーされたらバックグラウンド ジョブを実行することを考えました。
たとえば、flask に http リクエストでプロセスを開始させたいのですが、開始時にタスクを rabbitMQ キューにプッシュしたいのですが、消費者は同じアプリにいるべきですか、それとも別のサービスにいるべきですか?
python - _AsyncBaseTransport._consume() での RabbitMq Pika ConnectionResetError
rabbitmq に pika を使用するフラスコ アプリで以下のエラーを観察すると、
pika バージョン 1.1.0 を使用する rabbitmq バージョン 3.8.5
注: 構成されたハートビート値は 900 です (実行時間が長いため、より高い値が設定されているため、pika と rabbitmq 間の接続を維持する必要があります)
一定期間後に接続が失われた場合、アプリを再起動してrabbitmqにもう一度接続する必要があります。正確に何がうまくいかないのか、誰かが私を正しい方向に向けることができますか!