Tag: aiohttp

Python http Client / Server für asyncio (PEP-3156)

Asyncio + aiohttp - redis Pub/Sub-und websocket-Lesen/schreiben in Einzel-handler

Anzahl der Antworten 2 Antworten
Zur Zeit Spiele ich mit aiohttp zu sehen, wie es ausgeführt wird, als server-Anwendung für mobile app mit websocket-Verbindung. Hier ist ein einfaches "Hello world" - Beispiel (als Kernaussage hier): import asyncio import aiohttp from aiohttp import

asyncio web scraping 101: Holen Sie mehrere urls mit aiohttp

Anzahl der Antworten 2 Antworten
In der früheren Frage, einer der Autoren der aiohttp freundlicherweise vorgeschlagenen Weg zu Holen Sie mehrere urls mit aiohttp mit dem neuen async with syntax von Python 3.5: import aiohttp import asyncio async def fetch(session, url): with

aiohttp: wie-zum abrufen der Daten (body) in aiohttp server von Anfragen.erhalten

Anzahl der Antworten 2 Antworten
Könnten Sie bitte beraten Sie zu folgenden? Auf die localhost:8900 es ist aiohttp server mit Wenn ich eine Anfrage wie (mit der python2-Modul-requests) vom python requests.get("http://127.0.01:8900/api/bgp/show-route", data={'topo':"switzerland", 'pop':"zrh", 'prefix':"1.1.1.1/32"}) Und es ist eine route definiert, die in

Asyncio Absturz mit Laufzeitfehler: - Event-Schleife ist Geschlossen

Anzahl der Antworten 2 Antworten
Ich versuche, mich eine Reihe von Anfragen (~1000) mithilfe von Asyncio und die aiohttp Bibliothek, doch habe ich ein problem, ich kann nicht finden, viel info auf. Wenn ich diesen code ausführen, mit 10 urls, läuft es

Wie zu beheben TypeError: object str) kann nicht verwendet werden, 'erwarten' expression?

Anzahl der Antworten 1 Antworten
Ausführen des folgenden Codes: async def generate_url(self, ding_id): data = await self.s3.generate_presigned_url( ClientMethod='get_object', Params={ 'Bucket': '...', 'Key': '{}.mp4'.format(ding_id) } ) return data def convert_to_json(self, data): loop = asyncio.get_event_loop() for ding in dings: tasks.append(self.generate_url(ding)) video_ids = loop.run_until_complete(asyncio.gather(*tasks)) loop.close()

Wie überprüfen Sie ein SSL-Zertifikat Ablaufdatum mit aiohttp?

Anzahl der Antworten 3 Antworten
Ich wissen, wie man die Zertifikat-Informationen wie Ablaufdatum mit pyopenssl zum Beispiel, aber ist es möglich, es zu tun mit einem aiohttp response-Objekt? InformationsquelleAutor azmeuk | 2017-05-31

Absturz mit Laufzeitfehler: Es gibt keine aktuellen Ereignis-Schleife in thread im asynchronen + apscheduler

Anzahl der Antworten 2 Antworten
Ich habe eine async-Funktion und müssen laufen mit apscheduller alle N Minuten. Es ist ein python-code unter URL_LIST = ['<url1>', '<url2>', '<url2>', ] def demo_async(urls): """Fetch list of web pages asynchronously.""" loop = asyncio.get_event_loop() # event loop

Wie kombiniere ich Python-Asyncos mit Threads?

Anzahl der Antworten 2 Antworten
Habe ich erfolgreich gebaut Erholsamen microservice mit Python asyncio und aiohttp, hört auf ein POST-event zum sammeln von Echtzeit-Ereignissen aus verschiedenen Feedern. Anschließend erstellt es eine speicherinterne Struktur, die zum Zwischenspeichern der letzten 24h von Veranstaltungen in

"Async mit" in Python 3.4

Anzahl der Antworten 2 Antworten
Der Getting-Started-docs für aiohttp geben Sie den folgenden client-Beispiel: import asyncio import aiohttp async def fetch_page(session, url): with aiohttp.Timeout(10): async with session.get(url) as response: assert response.status == 200 return await response.read() loop = asyncio.get_event_loop() with aiohttp.ClientSession(loop=loop) as