接続がアイドル状態の場合は停止channel.basic_consume /長時間使用しない場合

Question

pikaコンシューマ（pika.BlockingConnection）の最後のアイドル時間（最後のメッセージ処理時間）を取得したい場合があります。
ユーズケース：
最後に処理された時間がしきい値時間（例：1時間）より大きい場合。私は消費者が出かけるか、または私が何をする必要があるかを決めるコールバックメソッドを持ってほしいですか？ユーザーに通知を送信する。

これを行う方法はありますか？

Answer 1

ナキウサギはtimeout callback.

あなたはそれへの参照を保持し、各メッセージ受信の開始時に、それを削除し、各メッセージの領収書の最後にこのコールバックを追加することができますサポートしています。

def close_connec(): 
    # close here 

timer_id = None 

def on_message(chan, method, props, body): 
    if timer_id is not None: 
     chan.connection.remove_timeout(timer_id) 
    # process message 
    timer_id = chan.connection.add_timeout(3600, close_connec)