I am using a mongodb change stream that listens for changes on a collection and runs a handler function that handles the change. I want each change coming in to be handled concurrently async def handle_collection_changes( *, change_stream, handler, handler_args,…
We are using Azure Conversation Transcriber for realtime speech to text with diarization. We need to incorporate the pause_resume feature. We tried different ways but nothing worked. Azure only provides stop_transcribing_async() function that completely stops the current session. I have…
I'm trying to run two coroutines together and using async, one is teleton telegram client and one async task who get data every minute for the telegram bot. Some code: from asyncio import Runner from asyncio import sleep import asyncio…
When using asyncio and aiohttp, faced this issue and was wondering if it was an occurance limited to VSC only? This one keeps leaving residues from the previous loops. while True: loop.run_until_complete(get_data()) This runs without any residual tasks. while True:…
I am using Starlette framework for my website and using websockets. I have a class that derives from WebSocketEndpoint that handles the incoming websocket connections. I have another class that I am using to manage Pub/Sub on Redis. I am…
I am developing a telegram bot using python-telegram-bot. It is like a stock screener, it analyzes the market every given interval and sends the results to users that are subscribed to the indicator. The problem is I do not want…
I encounter a RuntimeError: Event loop is closed error when trying to run asyncio.run() multiple times with Firebase. Is this expected? Here is a simplified example of the issue: import streamlit as st import firebase_admin from firebase_admin import credentials, firestore_async…
I am trying to write tests for an asyncio-based Python app that uses Redis. I reproduced the Python code from the official Redis as a document database quick start guide and turned it into tests: import pytest from redis.asyncio import…
When running my code I realized that after around 30 requests it gets very slow to fetch the rest, taking a long time to complete the code. My goal with this code is to fetch users from a Telegram's group…
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…