There are about 1M images, I need to read them and insert the bytes into redis with python. I have two choices, the first is to use a thread pool, and the second is to use asyncio, since this is…
I am using the following script to do queries on a website. It works on macos, however it does not work with ubuntu. I have tried requests and it works, I also tried a simple asyncio + requests with the…
For the sake of studying the capabilities of the Telegram API, the question arose, how to get the @username of a bot in a telegram using aiogram? I tried username = bot.get_me().username but gives the following error: AttributeError: 'coroutine' object…
I am currently working on building low latency model inference API using fast API, we are using azure redis cache standard version for fetching features and onnx model for fast model inference. I am using aioredis to implement concurrency for…
I need to test my telegram bot. To do this I need to create client user to ask my bot. I found telethon library which can do it. First I wrote a code example to ensure that authorisation and connection…
I'm trying to make a Telegram bot that parses GTFS data and returns the user the status of subway trains. I'm using the python-telegram-bot library and, so far, the bot I created work as intended. However, I wrote some very…
I build a chatapplication using Aiohttp server and using python-socket-io. When i tried to host this application in nginx i found this error in supervisor error from error log of supervisor(error log path= /var/log/gunicorn/gunicorn.err.log ) [2022-05-27 04:16:31 +0000] [32957] [ERROR]…
I get this exception: "Exception has occurred: AttributeError __aenter__" in line async with bot:. (I entered the token). Please help import asyncio import telegram async def main(): bot = telegram.Bot("token") async with bot: print(await bot.get_me()) if __name__ == '__main__': asyncio.run(main())…
I am doing some heavy processing that needs async methods. One of my methods returns a list of dictionaries that needs to go through heavy processing prior to adding it to another awaitable object. ie. def cpu_bound_task_here(record): ```some complicated preprocessing…
The documentation of asyncio.create_task() states the following warning: Important: Save a reference to the result of this function, to avoid a task disappearing mid execution. (source) My question is: Is this really true? I have several IO bound "fire and…