Verwenden der Methode der Abonnierung () in einem Asyncio -Stack ⇐ Python

[Anonymous]

Ich möchte PubSub in einer Anwendung verwenden, die Asyncio als grundlegende Möglichkeit zum Erreichen von E/A -Parallelität verwendet. Der Standard-Google SDK bietet jedoch keine asynchronen Methoden (ich habe GCLOUD-AIO-PUBSUB ausprobiert, aber es unterstützt nur Pull-Methoden, sodass die Latenz sehr schlecht ist). und Thema/Abonnementverwaltung Ich könnte nur Wrap_Future als Publish () -Methode und die meisten anderen zurückgeben, die ein Objekt zurückgeben, das zukünftige Protokoll unterstützt. Code> Methode. Gemäß der Dokumentation wird der StreamingPull in einem separaten Thread ausgeführt. Wenn ich den Code richtig verstehe, sehe ich, dass der Rückruf in einer Bedrohung aufgerufen wird, die aus einem Pool entnommen wird. < /P>
Meine Idee, ihn mit Asyncio zu verwenden mit einer, die die Coroutinen in der Ereignisschleife des Haupt -Threads planen würde. Ist es ein guter Ansatz? Irgendwelche Überlegungen, die ich berücksichtigen muss?