ist es möglich, alle blockierten Tornado-Korutinen aufzulisten

Question

Ich habe eine "Gateway" -App in tornado mit @tornado.gen.coroutine geschrieben, um Informationen von einem Handler zum anderen zu übertragen. Ich versuche, einige Debugging/Status-Tests zu machen. Was ich gerne tun könnte, ist, alle aktuell blockierten/wartenden Coroutinen aufzulisten, die zu einem bestimmten Zeitpunkt live sind. Ist diese Information irgendwo im Tornado zugänglich?

Answer 1

Nein, es ist nicht, aber man könnte vielleicht Ihre eigenen Dekorateur erstellen, die gen.coroutine Wraps, aktualisiert dann eine Datenstruktur, wenn die Koroutine beginnt.

import weakref 
import functools 

from tornado import gen 
from tornado.ioloop import IOLoop 

all_coroutines = weakref.WeakKeyDictionary() 


def tracked_coroutine(fn): 
    coro = gen.coroutine(fn) 

    @functools.wraps(coro) 
    def start(*args, **kwargs): 
     future = coro(*args, **kwargs) 
     all_coroutines[future] = str(fn) 
     return future 

    return start 


@tracked_coroutine 
def five_second_coroutine(): 
    yield gen.sleep(5) 


@tracked_coroutine 
def ten_second_coroutine(): 
    yield gen.sleep(10) 


@gen.coroutine 
def tracker(): 
    while True: 
     running = list(all_coroutines.values()) 
     print(running) 
     yield gen.sleep(1) 


loop = IOLoop.current() 
loop.spawn_callback(tracker) 
loop.spawn_callback(five_second_coroutine) 
loop.spawn_callback(ten_second_coroutine) 
loop.start() 

Wenn Sie dieses Skript für ein paar Sekunden laufen werden Sie zwei aktive Koroutinen sehen, dann eine, dann keine.

Beachten Sie die warning in the docs about the dictionary changing size, sollten Sie "RuntimeError" in "Tracker" abfangen, um mit diesem Problem umzugehen.

Dies ist ein bisschen komplex, Sie könnten alles, was Sie brauchen, viel einfacher erhalten, indem Sie die Protokollierung von Tornado aktivieren und set_blocking_log_threshold verwenden.

Answer 2

Sie sprechen über Ioloop _handlers dict vielleicht. Versuchen Sie, diese in regelmäßigen Rückruf hinzuzufügen:

def print_current_handlers(): 
    io_loop = ioloop.IOLoop.current() 
    print io_loop._handlers 

Update: Ich Quellcode überprüft haben und jetzt denken, dass es keine einfache Möglichkeit, verfolgen laufenden gen.corouitines, A. Jesse Jiryu Davis ist richtig!

Aber Sie können alle „async“ Anrufe (Erträge) aus Koroutinen Spuren - jede Ausbeute von Generator gehen in IOLoop.add_callback (http://www.tornadoweb.org/en/stable/ioloop.html#callbacks-and-timeouts)

also durch io_loop._callbacks Prüfung können Sie sehen, was jetzt Ausbeuten sind in ioloop.

Viele interessante Sachen hier :) https://github.com/tornadoweb/tornado/blob/master/tornado/gen.py