如何在 Slackbot 中发送进度消息-解网

问：

我有这个松弛机器人，它在收到消息时执行长时间运行的任务。我想发送一条初始的“正在加载....”消息，然后如果任务的执行时间超过 ~15 秒，我会将上一条消息更新为“仍在加载...”。

我不确定如何解决这个问题，因为我的程序没有使用 AsyncApp，我能想到的唯一解决方案是使用asyncio.wait_for

我尝试使用更新消息，但即使我将超时设置为 1，更新也从未执行。此外，long_running_task（）函数最初不是协程，因此它无法正常运行。asyncio.wait_for(task(), timeout=15)

app = App()

async def long_running_task():
    ...

@app.event("message")
def event_message(client, event, say, logger):
    initial_message = say("Loading")
    start_message_ts = initial_message["ts"]

    async def run_task():
        try:
            await asyncio.wait_for(long_running_task(), timeout=15)

        except asyncio.TimeoutError:
            await client.chat_update(
                channel=event["channel"],
                ts=start_message_ts,
                text="Still loading..."
            )

    asyncio.ensure_future(run_task())

异步 python-asyncio slack-api

from threading import Thread
import time

app = App()

def long_running_task():
    ...

@app.event("message")
def event_message(client, event, say, logger):
    initial_message = say("Loading")
    start_message_ts = initial_message["ts"]

    thread = Thread(target=long_running_task, daemon=True)
    thread.start()
    started = time.time()
    while thread.is_alive():
        if time.time()-started>15:
            client.chat_update(channel=event["channel"],ts=start_message_ts,text="Still loading...")
            break
        time.sleep(0.1)#Save CPU

（为了简单起见，我没有等待，但如果需要，您只需使用 asyncio 启动它）client.chat_update

如何在 Slackbot 中发送进度消息

How to send progress message in Slackbot

评论

评论