Issue with Telegram Bot Client Connection

Other Questions Telegram bot
1

I am working on a Telegram bot that is intended to share images from a specific subreddit, but I’m encountering an error that I am unable to resolve. Although I can’t disclose certain sensitive information for security reasons, I believe that it is not crucial for understanding the problem. Here’s a snippet of my code:

session_instance = <aiohttp.ClientSession object at 0x00000123456789AB>

config.py:

settings = {
    "CLIENT_KEY": "(hidden)",
    "SECRET_KEY":"(hidden)",
    "API_KEY":"(hidden)"
}

telegram_bot.py:

import asyncio
import aiohttp
import config
import asyncpraw
from aiogram import Bot, types

TOKEN = config.settings["API_KEY"]
CHANNEL = -1001234567890

bot = Bot(token=TOKEN, parse_mode=types.ParseMode.HTML)

reddit_instance = asyncpraw.Reddit(client_id=config.settings["CLIENT_KEY"],
                                    client_secret=config.settings["SECRET_KEY"],
                                    user_agent="subreddit_bot/0.1")

memes_list = []
DELAY = 5
TARGET_SUBREDDIT = "memes"
LIMIT = 1

async def post_message(channel_id: int, content: str):
    await bot.send_message(channel_id, text=content)

async def execute():
    while True:
        await asyncio.sleep(DELAY)
        submissions = await reddit_instance.subreddit(TARGET_SUBREDDIT)
        new_memes = submissions.new(limit=LIMIT)
        meme_item = await new_memes.__anext__()
        if meme_item.title not in memes_list:
            memes_list.append(meme_item.title)
            await post_message(CHANNEL, meme_item.url)

asyncio.get_event_loop().run_until_complete(execute())

Can anyone help me identify the problem?

2

It seems like the code does not include initialization for the aiohttp ClientSession that you indicated earlier in your question. Ensure that you are correctly initializing and managing the lifecycle of aiohttp ClientSession. Typically, you should create a session before making any asynchronous HTTP requests, and although it doesn’t appear directly used in your provided code, if any component in your actual implementation relies on it, you should ensure that you close the session when it’s no longer needed. This is essential to avoiding resource leaks and potential connection issues. Additionally, ensure you’re using the async function for correctly awaiting responses while dealing with Reddit’s API.

3

One issue might relate to the asyncio event loop management. asyncio.get_event_loop().run_until_complete(execute()) is blocking and might not be the best way to run tasks if there are other asynchronous operations. Instead, consider restructuring to use asyncio.run() which ensures that the event loop is closed properly when finished. Another debugging tip is to check if the version of the libraries used is compatible and updated, as older versions could cause unexpected behavior or errors.

4

It sounds like there’s a potential issue with your usage of asyncpraw as you’re processing the new subreddit submissions. Make sure the subreddit object and its methods are correctly awaited and async-praw is set up for asyncio use. Additionally, double-check your credentials and permissions; errors in credentials can sometimes manifest in obscure ways. Also, try to add some logging throughout your async function executions to have a better understanding of where the process might be failing or hanging.