Articles of asíncrono

Recuperación asincrónica de información de un proceso.

Aquí está el pseudo código para lo que quiero hacer. import time def run(): while x < 10000000: x += 1 if __name__ == "__main__": p = Process(run) p.start() time.sleep(3) #some code that I don't know that will give me the current value of x El módulo de threading Pythons parece ser el camino a […]

¿Cuáles son las diferencias entre los propósitos de las funciones del generador y las funciones del generador asíncrono?

En Python, las funciones del generador asíncrono son coroutines, y las funciones del generador también son coroutines. ¿Cuáles son las diferencias entre los propósitos de las funciones del generador y las funciones del generador asíncrono? Gracias.

Trabajo de consulta asíncrona de BigQuery: el método fetch_results () devuelve un número de valores incorrecto

Estoy escribiendo el código de Python con la API de BigQuery Client e bash usar el código de consulta asíncrono (escrito en todas partes como un ejemplo de código), y está fallando en la llamada al método fetch_data (). Python se equivoca con el error: ValueError: demasiados valores para descomprimir Por lo tanto, los 3 […]

Python asyncio con Slack bot

Estoy tratando de hacer un simple Slack bot usando asyncio, en gran parte usando el ejemplo aquí para la parte de asyncio y aquí para la parte de Slack bot. Los dos ejemplos funcionan por sí solos, pero cuando los pongo juntos parece que mi bucle no se repite: pasa una vez y luego muere. […]

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 {{ […]