krubsburger's questions

我正在写一个电报机器人aiogram，它的功能之一是显示我在market.csgo.com上的账户余额。该函数工作在异步模式下，发送 API 请求并通过await bot.send_message. 现在功能的启动是通过键盘按键来实现的。编码：

...

async def get_balance(session, profiles_dict, message):
    async with session.get(f'https://market.csgo.com/api/v2/get-money?key={profiles_dict[1][1]}') as resp:
        html_1 = await resp.json()

        each_wallet = int(html_1['money'])

        await bot.send_message(message.from_user.id, f'{profiles_dict[1][0]}: {each_wallet} ₽')


@dp.message_handler(content_types=['text'])
async def main(message):
    profiles = users()

    async with aiohttp.ClientSession(trust_env=True) as session:
        tasks = []

        if message.text == 'Balance 💸':
            await bot.send_message(message.from_user.id, 'Information request. Wait..')

            for i in profiles.items():
                task = asyncio.ensure_future(get_balance(session, i, message, stats))
                tasks.append(task)
            await asyncio.gather(*tasks)

        if message.text == 'Check Ban':
            ...

        if message.text == 'List Accounts':
            ...


if __name__ == '__main__':
    executor.start_polling(dp, skip_updates=False)

但是如何让它被调用，让我们说每个小时？我知道有一个异步版本的调度程序aioschedule，并且看过这个例子。但是他们运行一个没有参数的函数，但我有多达 3 个。我试着这样做：

async def scheduler(session, profiles_dict, message):
    aioschedule.every().day.at("12:00").do(get_balance(session, profiles_dict, message))
    while True:
        await aioschedule.run_pending()
        await asyncio.sleep(1)


async def on_startup(session, profiles_dict, message):
    asyncio.create_task(scheduler(session, profiles_dict, message))


if __name__ == '__main__':
    executor.start_polling(dp, skip_updates=False, on_startup=on_startup(session, profiles_dict, message))

但显然它不是那样工作的。从这里开始，问题是：如何运行一个aiohttp通过调度程序执行异步请求aioschedule并将结果作为消息发送到电报的函数aiogram？

有一个通过 API 发送请求的异步函数。我需要检查一个空响应，但由于某种原因它print(html_3['items'] is None)说False，虽然响应是空的。问题是什么？

...

async with session.get(f'https://market.csgo.com/api/v2/my-inventory/?key={profiles_dict[1][1]}') as resp_3:
    html_3 = await resp_3.json()
    print(html_3['items'])
    print(html_3['items'] is None)

...

回答：

[]
False
[]
False
[]
False
[]
False
[]
False
[]
False
[]
False
[{'id': '23354298822', 'classid': '310777025', 'instanceid': '0', 'market_hash_name': 'Dual Berettas | Colony (Minimal Wear)', 'market_price': 0.69, 'tradable': 1}]
False
[]
False
[]
False
[]
False

Process finished with exit code -1

我正在编写一个个人电报机器人来收集我的market.csgo.com帐户的统计数据。该机器人的主要任务是向 API 发送异步请求并通过 Telegram 显示信息。一切正常，但问题在于全局变量，或者更确切地说，它们的计数不正确。我的功能之一的示例：

...
import asyncio
import aiohttp


sale_total_sum = 0
amount_total_items = 0

async def get_on_sale(session, dictt, message):
    global sale_total_sum
    global amount_total_items

    async with session.get(f'https://market.csgo.com/api/v2/items?key={dictt[1][1]}') as resp:
        html = await resp.json()
        
        if html['items'] is None:
            pass
        else:
            each_sale_sum = 0
            each_amount_items = 0
            
            for i in html['items']:
                sale_total_sum += i['price']
                each_sale_sum += i['price']
                each_amount_items += 1
                amount_total_items += 1
               
            try:
                await bot.send_message(message.from_user.id,
                    f'<a href="{dictt[1][0]}">{dictt[0]}</a> : <b>{each_sale_sum} ₽</b>\nItems: <i>{each_amount_items}</i>',
                    disable_web_page_preview=True, parse_mode=types.ParseMode.HTML)
            except exceptions.RetryAfter as e:
                await asyncio.sleep(e.timeout)


@dp.message_handler(content_types=['text'])
async def Main(message):
    profiles = users()
    
    async with aiohttp.ClientSession(trust_env=True) as session:
        tasks = []
        
        if message.text == 'On Sale 💰':
            await bot.send_message(message.from_user.id, 'Information request. Wait..')
           
            for i in profiles.items():
                task = asyncio.ensure_future(get_on_sale(session, i, message))
                tasks.append(task)
            await asyncio.gather(*tasks)
            
            await bot.send_message(message.from_user.id,
                f'<b>Total on sale: {sale_total_sum} ₽\nTotal items: {amount_total_items}\nBot start at: {start}</b>',
                reply_markup=kb_client, parse_mode=types.ParseMode.HTML)


executor.start_polling(dp, skip_updates=True)

函数结果：

Account_1: 100 ₽
Items: 1
Account_2: 200 ₽
Items: 2
Account_3: 300 ₽
Items: 3
Total on sale: 600 ₽
Total items: 6

该机器人在轮询模式下工作executor.start_polling(dp, skip_updates=True)。如果在包含后第一次调用该函数async def get_on_sale，那么它的最终计数Total on sale: 600 ₽ Total items: 6将是正确的，但随后的调用会使这个数量翻倍，实际上并非如此：

Account_1: 100 ₽
Items: 1
Account_2: 200 ₽
Items: 2
Account_3: 300 ₽
Items: 3
Total on sale: 1200 ₽
Total items: 12

我知道问题出在全局变量global sale_total_sum和global amount_total_items. 但是，如果您改用简单变量，它们将被简单地覆盖，而不是按照我的需要进行汇总。因此，我想问 -有没有办法在函数结束后以某种方式重置或重新分配这些全局变量为 0？这样在下一次调用时数据将是正确的。谢谢你。