Suchergebnisse für Anfrage "python-asyncio"
Starten Sie die Async-Funktion, ohne das Asyncio-Paket zu importieren
Is ist möglich, eine Funktion wie diese zu starten async def foo(): while True: print("Hello!")ohne das @ zu importierasyncio package (und die Ereignisschleife abrufen)? Ich suche nach einem Prinzip, das Go's Goroutinen ähnelt und bei dem man ...
Asyncio dekodiert utf-8 mit StreamReader
Ich gewöhne mich an Asyncio und finde die Aufgabenabwicklung ganz nett, aber es kann schwierig sein, Async-Bibliotheken mit herkömmlichen Io-Bibliotheken zu mischen. Das Problem, mit dem ich derzeit konfrontiert bin, besteht darin, ...
Wie erkenne ich einen Schreibfehler in asyncio?
Betrachten Sie als einfaches Beispiel das Netzwerkäquivalent von / dev / zero (siehe unten). (Oder realistischer, nur ein Webserver, der eine große Datei sendet.) Wenn ein Client die Verbindung vorzeitig trennt, werden ...
wie füge ich einer laufenden asynchronen Schleife eine Coroutine hinzu?
Wie kann man einer laufenden Asyncio-Schleife eine neue Coroutine hinzufügen? Dh eine, die bereits eine Reihe von Koroutinen ausführt. Ich vermute, als Workaround kann man warten, bis vorhandene Coroutinen fertig sind, und dann eine neue ...
Verspotten eines asynchronen Aufrufs in Python 3.5
Wie verspotte ich einen asynchronen Aufruf von einer nativen Coroutine zu einer anderen mit unittest.mock.patch? Ich habe derzeit eine ziemlich umständliche Lösung: class CoroutineMock(MagicMock): def __await__(self, *args, **kwargs): future ...
Wie kann ich eine asynchrone Iterationsdatei asynchron zuordnen / filtern?
Sagen wir, ich habe eine asynchrone iterable, die ich mit @ übergeben kaasync for, wie kann ich es dann einem neuen asynchronen Iterator zuordnen und filtern? Der folgende Code, der eine Anpassung dessen ist, wie ich das Gleiche mit ...
Asyncio-Tasks an Schleife senden, die in einem anderen Thread ausgeführt wird
Wie kann ich Aufgaben asynchron einfügen, um sie in einem @ auszuführeasyncio Event-Schleife läuft in einem anderen Thread? Meine Motivation ist es, interaktive asynchrone Workloads im Interpreter zu unterstützen. Ich kann den Haupt-REPL-Thread ...
Wie können Sie bei Verwendung von asyncio zulassen, dass alle ausgeführten Aufgaben beendet werden, bevor Sie die Ereignisschleife beenden?
Ich habe den folgenden Code: @asyncio.coroutine def do_something_periodically(): while True: asyncio.async(my_expensive_operation()) yield from asyncio.sleep(my_interval) if shutdown_flag_is_set: print("Shutting down") breakIch führe diese ...
Wie rufen wir eine normale Funktion auf, bei der eine Coroutine erwartet wird?
Betrachten Sie eine Coroutine, die eine andere Coroutine aufruft: async def foo(bar): result = await bar() return resultDies funktioniert gut, wennbar ist eine Coroutine. Was muss ich tun (d. H. Womit muss ich den Anruf an @ beendenbar) damit ...
Was bedeutet "SSLError: [SSL] PEM lib (_ssl.c: 2532)", dass die Python-SSL-Bibliothek verwendet wird?
Ich versuche, mit dem Python 3-Asyncio-Modul eine Verbindung zu einer anderen Partei herzustellen, und erhalte den folgenden Fehler: 36 sslcontext = ssl.SSLContext(ssl.PROTOCOL_TLSv1) ---> 37 sslcontext.load_cert_chain(cert, keyfile=ca_cert) 38 ...