How can i fix Task was destroyed but it is pending? – Debian
I have a problem. So I have a task that runs every time when a user writes a chat message on my discord server - it's called on_message. So my bot has many things to do in this event, and…
How to use asyncio and aioredis lock inside celery tasks?
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…
RuntimeWarning: coroutine 'function' was never awaited – Telegram API
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,…
RuntimeWarning , RuntimeError (Python Al Chat Bot on Discord Server) – Artificial Intelligence
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…
Why redis stream consumers should specify an individual name in the same consumer group?
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…
How to have two client Telethon running concurrently – Telegram API
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…
Asynchronous code failure when connecting to redis
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')…
Telethon – Save Telegram channel message as a variable from a NewMessage event – Telegram API
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…
asyncio not working on Google Cloud Functions – Telegram API
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 =…
Redis – Run slow background blocking task from asyncio loop
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):…