したがって、この 2 つのアプリケーションを REST API (json メッセージ) に接続しています。1 つは Django で記述され、もう 1 つは Php で記述されています。両側に正確なデータベースのレプリカがあります (mysql を使用)。
それらの1つで「送信」を押すと、そのデータを現在のアプリデータベースに保存し、セロリ/redisでcronジョブを開始して、残りを使用して他のアプリのリモートデータベースを更新します。
私の質問は、FIFO の順序を維持するために、同じワーカーを自分のタスクに割り当てるにはどうすればよいですか?
データの一貫性が必要であり、FIFO は非常に重要です。
わかりました、もう少しやりたいことを詳しく説明します。
だから私はこのジャンゴアプリを持っています。フォームに入力した後に送信を押すと、セロリワーカーが目を覚まし、送信されたデータを取得してリモートサーバーに投稿します。これなら問題なくできます。
さて、私のインターネットがその正確な時間にダウンしたと想像してください。セロリワーカーは送信が成功するまで再試行し続けますが、以前のデータが送信される前に別の送信を行うと想像してください。
今、それが私の問題です。セロリが提供する再試行オプションを使用してこのリクエストをFIFOにすることができないので、それを理解するのに助けが必要です。