Category "python-asyncio"

python websockets set port as None, how can get which port used?

I used python websockets library create a websocket server, to avoid port has been used by other application, I set port as None, let system choose a port for m

How stream a response from a Twisted server?

Issue My problem is that I can't write a server that streams the response that my application sends back. The response are not retrieved chunk by chunk, but fro

ValueError: set_wakeup_fd only works in main thread on Windows on Python 3.8 with Django 3.0.2 or Flask 2.0.0

When I run my Django Web application with Apache2.4.41 + Python 3.8.1 + Django 3.0.2 + MySQL 8.0.19 on Windows 10 Professional version it throws Value Error at

Unable to achieve async/parallel behavior inside for loop while using FastAPI and Ormar

I am using FastAPI and have an async route that needs to do many things like making calls to other API endpoints, and reading/writing to a database. It iterates

Watch stdout and stderr of a subprocess simultaneously

How can I watch standard output and standard error of a long-running subprocess simultaneously, processing each line as soon as it is generated by the subproces

How to get IP address and port of newly accepted connection in Python asyncio server?

I'm using the asyncio library in Python 3.8 https://docs.python.org/3/library/asyncio.html I am creating a server, and in the "newly accepted connection" callb

asyncio not working on Google Cloud Functions

I have this function which works fine locally on my machine with python 3.8, but it throws runtime error on Google Cloud Functions. def telegram_test(request):

Is there a way to take advantage of multiple CPU cores with asyncio?

I've created a simple HTTP Server with python and asyncio. But, I have read that asyncio-based servers can only take advantage of one CPU core. I am trying to f

Getting live output from asyncio subprocess

I'm trying to use Python asyncio subprocesses to start an interactive SSH session and automatically input the password. The actual use case doesn't matter but i

Python discord bot - coroutine was never awaited

I'm working on a Discord bot and it works to some degree but it keeps crashing every couple minutes. It gives me an error like Task was detroyed but it's pendi

FastAPI runs api-calls in serial instead of parallel fashion

I have the following code: import time from fastapi import FastAPI, Request app = FastAPI() @app.get("/ping") async def ping(request: Request):

ThreadPoolExecutor communication with separate asyncio loop

I have a task that is IO bound running in a loop. This task does a lot of work and is often times hogging the loop (Is that the right word for it?). My plan is

How to make request without blocking (using asyncio)?

I would like to achieve the following using asyncio: # Each iteration of this loop MUST last only 1 second while True: # Make an async request sleep(1

asyncio and paramiko for concurrent ssh connectivity

I'm trying to speed up the Paramiko SSH connection to a couple of network devices. I want to use asyncio for that purpose, but I'm not sure if my implementation

uploading multiple files UploadFiles FastAPI

Example Here's my code: from typing import List from fastapi import FastAPI, File, UploadFile import asyncio import concurrent.futures app = FastAPI() @app.po

Python asyncio sleep not wakes up

I am trying yo have a progress indicator where one task is doing something while the other indicates a progress. My hello world version of this things goes to s

Django ORM and Async

So, I'm trying to create a polling system internal to django commands for fun and to learn async/django. I'm using django_tenants, although it's not overly impo

SqlAlchemy asyncio orm: How to query the database

In SqlAlchemy async orm engine how do I query a table and get a value or all? I know from the non async methods that I can just do SESSION.query(TableClass).get

Asynchronous exception handling in Python

I've the following code using asyncio and aiohttp to make asynchronous HTTP requests. import sys import asyncio import aiohttp @asyncio.coroutine def get(url):

Mac web requests hanging after thousands of requests

I'm facing a very strange issue and am looking for advice on how to debug it more than I am on a simple fix, since I've been unable to create a simple reproduci