問題タブ [php-enqueue]

シンフォニー 2.8

https://github.com/j-guyon/CommandSchedulerBundleを使用して、定期的なコマンドの実行を管理します。

これらの各コマンド実行は、コマンド引数に基づいて特定のサービスを呼び出します。

サービス (すべて同じインターフェイスを実装し、Abstract クラスを拡張する) にいるため、サブプロセスを作成して実行することを計画しています (可能であれば非同期で)。

あなたの経験に基づいて、そのサブプロセスに対処するための最良の方法はどれですか?

• サブプロセスごとに (コントローラーアクションに基づいて) Process オブジェクトを作成し、それらを同期的に実行します ( https://symfony.com/doc/2.8/components/process.html )

• https://php-enqueue.github.io/symfony やhttps://github.com/armetiz/LeezyPheanstalkBundleなど、キューバンドルの種類を使用してそれらすべて (プロセスまたはメッセージなど) を処理します (他の提案はありますか? )

乾杯！

php-enqueue コンシューマーの liveness と readiness プローブのヘルスチェックを行うにはどうすればよいですか?

コンシューマーは長時間実行されるプロセスであり、次のように開始されます。

通常、プロセスがダウンすると、k8s またはその他のスーパーバイザーによって再起動されます。しかし、消費者が立ち往生しているように見えても、プロセスが閉じられていない場合があります。

キューの問題は、非同期であることです。
メッセージをキューに送信できますが、メッセージが適切に消費されていることを確認するにはどうすればよいですか?
これには何らかのメカニズムがありますか？

私の考えは現在、ヘルスチェックイベントが消費されたときに、コンシューマーに別のキューにイベントを再度送信させることです。この他のキューは health-check コマンドによって消費され、正常に消費された場合、health-check は true を返します。
これは理にかなっていますか？

rabbit-mq transport でenqueue-bundleを使用してメッセージを遅らせるにはどうすればよいですか? 私はこのように試しました：

ただし、遅延は適用されません。(rabbitmq_delayed_message_exchange プラグインを有効にしています)