Category "python-asyncio"

Async SqlAlchemy with FastAPI: Getting single session for all requests

I have recently migrated a REST API coded with FastApi to the new SQLAlchemy 1.4+ Async Version. My app compiles correctly and the database seems to setup just

Why is asyncio session is closed error occurring with my Pymyq script?

I have written a script which uses the Python Pymyq library to interact with Chamberlin smart home devices, in this case a garage door. This script ran success

simultaneous (async) work - getting msg receiving and placing order/selling in auto bot w websocket

''' I would like to get async working for purchasing ordering while continuously getting realtime price update by websocket receving. However, when I execute th

How to profile/benchmark Python ASYNCIO code?

How do I profile/benchmark an assynchronous Python script (which uses ASYNCIO)? I you would usualy do totalMem = tracemalloc.get_traced_memory()[0] totalTime

Could not find platform dependent libraries <exec_prefix> Consider setting $PYTHONHOME to <prefix>[:<exec_prefix>] for Python 3.9

I am trying to install Python 3.9 in order to access some updated libraries compared to Python 3.6. However, when I run my code, none of the previous libraries

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