使用不和谐机器人发送高优先级和低优先级消息

Question

Discord 将机器人限制为每台服务器每 5 秒执行 5 次操作 - 因此，机器人尽可能快地响应紧急事务非常重要，即使这意味着降低其他事情的优先级。

我第一次尝试处理这个是这两个命令（特别是第一个使用时间模块）

@bot.command()
async def low_priority_count(ctx, num: int):

    for i in range(num):
        time.sleep(1)
        await ctx.send("low priority "+str(i))

@bot.command()
async def high_priority_count(ctx, num: int):

    for i in range(num):
        await ctx.send("high priority "+ str(i))
bot.run(TOKEN)

我的想法是，如果您调用 $high_priority_count 20，则循环将快速发送包含数字 0-19 的消息，尽管 discord 需要一些时间才能将它们打印出来。因此，我预计如果您调用 $low_priority_count 20，您会在高优先级消息之后收到低优先级消息。

相反，您可以将它们夹杂在一起。这是文本频道上消息的附加版本：

User:      $high_priority_count 20
Bot:       high priority 0
           high priority 1
           high priority 2
           ...
           high priority 9
User:      $low_priority_count 20
Bot:       high priority 10
           low priority 0
           high priority 11
           low priority 1
           high priority 12
           low priority 2
           ...
           high priority 19
           low priority 9
           low priority 10
           low priority 11
           low priority 12
           ...
           low priority 20

为什么机器人会一起发送消息？有没有办法确保在发送低优先级消息之前先发送高优先级消息？

Answer 1

您正在使用 time.sleep 这是一个阻塞函数，您不应该在异步代码中使用它。如果您使用asyncio.sleep，一切都应该按您的预期工作

import asyncio

@bot.command()
async def low_priority_count(ctx, num: int):
    for i in range(num):
        await asyncio.sleep(1)
        await ctx.send("low priority "+str(i))


@bot.command()
async def high_priority_count(ctx, num: int):
    for i in range(num):
        await ctx.send("high priority "+ str(i))

您还应该在high_priority_count 命令中添加延迟，在测试代码时，我已经多次达到速率限制。

编辑：

回答你的评论，这个比较复杂，你可以使用Synchronization Primitives。 asyncio.Semaphore 应该可以工作

bot.priority_semaphore = asyncio.Semaphore()

@bot.command()
async def high_priority_count(ctx, count: int):
    await bot.priority_semaphore.acquire()
    for i in range(count):
        await ctx.send(f"High priority {i}")

    bot.priority_semaphore.release()


@bot.command()
async def low_priority_count(ctx, count: int):
    await bot.priority_semaphore.acquire():
    for i in range(count):
        await asyncio.sleep(1)
        await ctx.send(f"High priority {i}")

    bot.priority_semaphore.release()

遗憾的是，如果您先调用low_priority_count 命令，它将首先发送低优先级消息，如果首先调用低优先级消息，我想不出一种首先发送高优先级消息的方法。