Articles of asíncrono

Usando threading.Timer con asycnio

Soy nuevo en la función de ascynio de python y tengo un servidor que procesa solicitudes de websocket desde un navegador. Aquí hay una versión simplificada de cómo funciona: @asyncio.coroutine def web_client_connected(self, websocket): self.web_client_socket = websocket while True: request = yield from self.web_client_socket.recv() json_val = process_request(request) yield from self.socket_queue.put(json_val) @asyncio.coroutine def push_from_web_client_json_queue(self): while True: json_val […]

Ejemplo asíncrono simple con tornado python

Quiero encontrar un ejemplo simple de servidor asíncrono. Tengo algunas funciones con mucha espera, transacciones de base de datos … etc: def blocking_task(n): for i in xrange(n): print i sleep(1) return i Necesito ejecutar la función en un proceso separado sin bloquear. ¿Es posible?

Python: ¿descarga asíncrona simple de contenido de url?

Tengo un servidor web.py que responde a varias solicitudes de los usuarios. Una de estas solicitudes consiste en descargar y analizar una serie de páginas web. ¿Existe una forma sencilla de configurar un mecanismo de descarga de url basado en async / callback en web.py? El bajo uso de recursos es particularmente importante ya que […]

¿Archivo asíncrono posible en python?

¿Existe una forma fácil de escribir en un archivo de forma asincrónica en Python? Sé que el archivo io que viene con Python está bloqueando; que está bien en la mayoría de los casos. Para este caso en particular, necesito escrituras para no bloquear la aplicación en absoluto, o al menos lo menos posible.

La respuesta HTTP de transmisión de tornado como AsyncHTTPClient recibe fragmentos

Estoy intentando escribir un controlador de solicitud de tornado que realiza solicitudes HTTP asíncronas y devuelve datos al cliente a medida que lo recibe de sus solicitudes asíncronas. Desafortunadamente, no puedo hacer que Tornado devuelva ningún dato al cliente hasta que se hayan completado todas las solicitudes HTTP Async. A continuación se muestra una demostración […]

Django – Cómo usar la cola de tareas asíncronas con apio y redis

#In my views.py file pi1 = None pis1 = None def my_func(): #Essentially this function sets a random integer to pi1 and pis1 global pi1, pis1 pi1 = randint(0,9) pis1 = randint(0,9) return def index(request): my_func() context = { “pi1” : pi1, “pis1” : pis1, } return render(request, “index.html”, context) #In the index.html file {{ […]

¿Cómo mostrar actualizaciones continuas en tiempo real como Facebook ticker, la página de inicio de meetup.com?

¿Cómo mostrar actualizaciones continuas en tiempo real en el navegador, como Facebook ticker, y la página de inicio de meetup.com? En Python, PHP, node.js y ¿cuál sería el impacto en el rendimiento en el lado del servidor? Además, ¿cómo podríamos lograr la misma actualización si la página es almacenada en caché por un CDN como […]

¿Cómo crear un bucle de eventos con coroutines rodantes ejecutándose para siempre?

Para evitar el cambio de contexto, quiero crear un gran bucle para atender tanto las conexiones de red como algunas rutinas. Aquí está la implementación para las funciones normales: import asyncio import time def hello_world(loop): print(‘Hello World’) loop.call_later(1, hello_world, loop) def good_evening(loop): print(‘Good Evening’) loop.call_later(1, good_evening, loop) print(‘step: asyncio.get_event_loop()’) loop = asyncio.get_event_loop() print(‘step: loop.call_soon(hello_world, loop)’) […]

Procesos asíncronos concurrentes con Python, Flask y Apio.

Estoy trabajando en una aplicación Python pequeña pero computacional intensiva. El trabajo de computación intensiva se puede dividir en varias partes que se pueden ejecutar simultáneamente. Estoy tratando de identificar una stack adecuada para lograr esto. Actualmente estoy planeando usar una aplicación Flask en Apache2 + WSGI con Celery para la cola de tareas. A […]

Twisted (servidor asíncrono) vs Django (o cualquier otro framework)

Necesito ayuda para comprender cuál es la ventaja de usar un marco asíncrono. Supongamos que quiero desarrollar una aplicación web de chat simple. ¿Por qué no puedo escribir código python en el marco de Django que hace un sondeo largo en el que no envío una respuesta al servidor hasta que alguien ingrese un nuevo […]