Goal: Possibility to run asyncio coroutines. Correct celery behavior on exceptions and task retries. Possibility to use aioredis lock. So, how to run async tasks properly to achieve the goal? What is RuntimeError: await wasn't used with future (below), how…
I have a class PersonalMessage with a function sendPersonalMessage that sends a message to a user in telegram. class PersonalMessage: def __init__(self): self.api_id = api_id, self.api_hash = api_hash, self.token = token, self.user_id_1 = user_id_1, self.phone = phone async def sendPersonalMessage(self,…
My Aim: Be able to integrate Al Chatbot and Discord import nltk nltk.download('punkt') from nltk.stem.lancaster import LancasterStemmer stemmer=LancasterStemmer() import numpy import tflearn import tensorflow import random import json import pickle import nest_asyncio import asyncio #--------------------------------------------------------------------------- import discord import os with…
The codes below show how I test the Redis stream functions. And I found that different processes with the same consumer name are competing to consume messages in the same stream. In my understanding, if this performance is normal, Redis…
I have two different Telegram chats. When the first one receives a message, it should wait for a message from another chat. After the second chat receives a message, it should stop running and retake the first chat. EXAMPLE: It…
I created a small class to perform basic operations with redis, using aioredis. class RedisService: def __init__(self, r_url) -> str: self.redis = r_url async def create_connection(self): return await aioredis.create_redis(self.redis) async def _get(self, key) -> str: try: return await self.create_connection().get(key, encoding='utf-8')…
Having read the following question: How to save message from telegram channel as variable I need to do the same but from a NewMessage event, storing the content of the message in a variable. However, neither event.text nor event.raw_test seem…
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): request_json = request.get_json() import datetime import pandas as pd from pyrogram import Client session_string =…
I have asyncio crawler, that visits URLs and collects new URLs from HTML responses. I was inspired that great tool: https://github.com/aio-libs/aiohttp/blob/master/examples/legacy/crawl.py Here is a very simplified piece of workflow, how it works: import asyncio import aiohttp class Requester: def __init__(self):…
I'm coding a telegram userbot (with telethon) which sends a message,every 60 seconds, to some chats. I'm using 2 threads but I get the following errors: "RuntimeWarning: coroutine 'sender' was never awaited" and "no running event loop". My code: ....…