Python Pika canal de déconnexion sur iddle

Question

J'ai des problèmes pour comprendre comment je peux définir un délai d'attente pour un canal iddle. J'ai trouvé cette réponse:

Stop channel.basic_consume if the connection is idle/Not consuming from long time

Mais la timer_id variable devient hors de portée dans ma méthode ON_MESSAGE.

Existe-t-il un moyen de déconnecter un canal quand aucun message n'est arrivé à la file d'attente dans un temps donné?

Merci pour votre aide

Answer 1

sûr que je peux vous aider. Pour de telles situations, j'ai choisi d'utiliser une méthode channel.consume(), cette méthode renvoie un itérateur de (méthode, propriétés, corps) et quand la file d'attente est vide et le délai dépassé, elle renvoie un (None, None, None) tuple. Il suffit de vérifier pour ne pas et aucun bam! là, vous avez votre méthode de fermeture plus une déconnexion:

for method, prop, body in channel.consume(queue='Q_test_timeout', 
              no_ack=True, 
              exclusive=True, 
              inactivity_timeout=3): 

Docs