I have some working code that I need to improve the run time on dramatically and I am pretty lost. Essentially, I will get zip folders containing tens of thousands of json files, each containing roughly 1,000 json messages. There…
Background Info My web app is built on top of async FastAPI. The server deploying this app will start 4 workers and each worker will start 2 threads for handling concurrent requests. Description Most services in my web app rely…
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…