問題タブ [python-pika]

私にとって解決策がなく、私の質問が他の質問と異なる可能性があるため、stackoverflowを検索してこの質問を投稿しました。

私は、rabbitMQ キューから記事を取得し、記事を処理して単語をカウントし、そこからキーワードを抽出して db にダンプするスクリプトを作成しています。私のスクリプトは正常に動作していますが、しばらく実行した後、この例外が発生します
(-1, "ConnectionResetError(104, 'Connection reset by peer')")

なぜこれを取得しているのかわかりません。私はスタックオーバーフローで利用可能な多くのソリューションを試しましたが、どれもうまくいきません。私は自分のスクリプトを書き、2 つの異なる方法で試しました。どちらも正常に動作しますが、しばらくすると同じ例外が発生します。

ここに私の最初のコードがあります:

ここに私の2番目のコードがあります:

最初のコードでは、記事の処理プロセスを高速化するためにスレッド化を使用しました。
これは私のコールバック機能です
def on_message(ch, method, properties, message): Logger.log_message("Starting parsing new msg ") handle_message(message)

編集:完全なコード

pika がメッセージを処理するのに多くの時間がかかっていないにもかかわらず、接続のリセットの問題に直面しています。
**メッセージの処理にかかった合計時間: 0.0005991458892822266 **