Arrêter channel.basic_consume si la connexion est inactive/Ne pas consommer depuis longtemps

Question

J'ai un cas d'utilisation dans lequel je veux obtenir le dernier temps d'inactivité (dernier temps traité) d'un consommateur pika (pika.BlockingConnection).
Usecase:
Si la dernière durée traitée est supérieure au temps limite (ex: 1 heure). Je veux que le consommateur soit sorti ou avoir une méthode de rappel pour décider de ce que je dois faire? Comme envoyer une notification à un utilisateur.

Y at-il un moyen de le faire?

Answer 1

pika soutient un timeout callback.

Vous pouvez ajouter ce rappel à la fin de chaque réception de message, en gardant la référence à, et le retirer au début de chaque réception de message.

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)