Suchergebnisse für Anfrage "python-asyncio"
Wie kann ich asynchrone Coroutinen schreiben, die optional als reguläre Funktionen fungieren?
Ich schreibe eine Bibliothek, die Endbenutzer optional verwenden können sollen, als ob ihre Methoden und Funktionen keine Coroutinen wären. Zum Beispiel mit dieser Funktion: @asyncio.coroutine def blah_getter(): return (yield ...
Asynchrone Ausnahmebehandlung in Python
Ich habe den folgenden Code mitasyncio undaiohttp um asynchrone HTTP-Anfragen zu stellen. import sys import asyncio import aiohttp @asyncio.coroutine def get(url): try: print('GET %s' % url) resp = yield from aiohttp.request('GET', url) ...
Wie erstelle ich eine Ereignisschleife mit fortlaufenden Coroutinen?
Um ein Umschalten des Kontexts zu verhindern, möchte ich eine große Schleife erstellen, um sowohl die Netzwerkverbindungen als auch einige Routinen zu bedienen. Hier ist die Implementierung für normale Funktionen: import asyncio import time ...
understanding asyncio läuft schon für immer loop und anstehende aufgaben
Ich habe Probleme zu verstehen, wie ich eine neue Aufgabe an eine bereits laufende Ereignisschleife anhängen kann. Dieser Code: import asyncio import logging @asyncio.coroutine def blocking(cmd): while True: logging.info("in blocking ...
Asyncio zwei Schleifen für verschiedene E / A-Aufgaben?
Ich verwende das Python3-Asyncio-Modul, um eine Lastausgleichsanwendung zu erstellen. Ich habe zwei schwere E / A-Aufgaben: Ein SNMP-Polling-Modul, das den bestmöglichen Server ermitteltEin "Proxy-ähnliches" Modul, das die Eingaben an den ...
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 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 ...
Mit Asyncio mehrere Anrufe tätigen und einem Wörterbuch ein Ergebnis hinzufügen
Ich habe Probleme damit, die Asyncio-Bibliothek von Python 3 im Voraus einzuschließen. Ich habe eine Liste mit Postleitzahlen und ich versuche, asynchrone Aufrufe an eine API zu senden, um für jede Postleitzahl die entsprechende Stadt und das ...
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 ...
Wann und wann sollte Python 3.5 nicht verwendet werden?
Ich bekomme den Fluss der Verwendung vonasyncio in Python 3.5, aber ich habe keine Beschreibung der Dinge gesehen, die ich sein sollteawaiting und Dinge die ich nicht sein sollte oder wo es vernachlässigbar wäre. Muss ich nur mein ...