Category "python-asyncio"

How to call async function in sync code and break async/await chain (i.e. how to wrap an async function in a sync function)

All my code is written without asyncio in mind; however, I use one function that is async (written by another developer; for my purposes it's a black box). Let'

AsyncIO coroutines with different IP's

I am building a python bot to check thousands of url json adresses and gather the information I need in these jsons. My problem at the moment is the speed, main

How to handle Firebase Cloud Messaging Notifications in Django?

I am managing to send FCM notifications to my app through Django. Here is my function for pushing notifications: import firebase_admin from firebase_admin impor

Python How to make function run simultaneously using asyncio

I am currently new to Python and wanted to create a system that takes 10 customers that come in at an interval of 1 - 25 seconds. They are sent to a queue, and

Can I await the same Task multiple times in Python?

I need to do a lot of work, but luckily it's easy to decouple into different tasks for asynchronous execution. Some of those depend on each other, and it's perf

Python asyncio program does not exit waiting for stdin input

I have a complex Python 3.9 program that does not exit if interrupted with Ctrl-C (SIGINT). The following is a minimal repro of the problem. Run with python sam

Using asyncio extension with SQLite backend broken by version upgrade

An upgrade from SQLAlchemy version 1.4.0b2 to 1.4.0b3 results in the following error when attempting to connect to a SQLite engine, using the asyncio extension.

Telegram Message Listener - RuntimeError: Event Loop is closed

I want to receive new messages from Telegram via a python script. I filter the message and then put out the result. But there is something wrong with the loop s

Proper syntax of parameters using function run_in_executor()

To make a POST call to the API, I use the following script: r = requests.post( url, headers={ "Content-Type": "application/json" }, json

Discord.py and Python Schedule, never awaited for?

I'm trying to send a message to a channel once a day at 02:39 using Schedule and Threading but I can't seem to get past asyncio "never awaited for". My code: @b

Python Asyncio/Trio for Asynchronous Computing/Fetching

I am looking for a way to efficiently fetch a chunk of values from disk, and then perform computation/calculations on the chunk. My thought was a for loop that

await vs asyncio.sleep: Does await keyword return control to the loop? Or maybe Pythons's asyncio StreamReader.read() is blocking?

I encountered a strange situation. StreamReader in asyncio seems to be blocking. received = asyncio.Queue() async def read_loop(): while True: rece

asyncio.wait not returning on first exception

I have an AMQP publisher class with the following methods. on_response is the callback that is called when a consumer sends back a message to the RPC queue I se

FastAPI - dynamic inputs for different data types

I have to create a very generic endpoint for a user. The user may send JSON data or may upload a file to this endpoint. There are multiple options on how to han

Python asyncio event loop add wait for server connection

I want to establish a connection with asyncio.open_connection but I can't get it to work. first I create the loop and a queue _loop = asyncio.new_event_loop() _

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

Other Categories