Category "python-asyncio"

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

How to read lines from file asynchronously and work with them in gather?

I'm trying to replace list of generated numbers with asynchronously reading them from file. How can I do it right? from asyncio import get_event_loop, gather, s

fastapi + aiomysql connection pool stuck after 10 calls

Why aiomysql connection pool stuck after N calls? (N is the maxsize number of connection. Tried the default N=10 and N=3) I thought the acquired connections are

Does the lock in asyncio.Condition have other purpose besides compatibility with threading.Condition?

I'd like to ask about asyncio.Condition. I'm not familiar with the concept, but I know and understand locks, semaphores, and queues since my student years. I c

Rest API asyncio gets stuck while running

Can anyone help me with Rest API asynchronous? I used Asyncio for 4 requests to FTX server. If I run the code, it prints 'balance','position','chart1','chart2'

Using next() on an async generator

A generator can be iterated step by step by using the next() built-in function. For example: def sync_gen(n): """Simple generator""" for i in range(n):