主页 / 问题 / 1538668
Accepted
Aliaksei Yurau
Asked:2023-09-01 21:29:58 +0000 UTC2023-09-01 21:29:58 +0000 UTC

每 10 分钟调用一次 Python 函数并停止该进程

  • 772

大家下午好！TG 机器人中有一个按钮，一个人点击它，时间应该开始倒计时，set_support 函数应该每 10 分钟调用一次，依此类推，直到我再次按下按钮。我已经玩过 Sleep 和 asyncio。我还没找到解决办法，请帮忙！我用艾图。有一个按钮：

support = KeyboardButton('Помощь')

我按下它，计时器应该启动，并且该功能应该每 10 分钟运行一次：

def set_support(active_collector):
date = datetime.date.today()
title = 'Помощь'
order_number = '-'
sql_select_query = """SELECT Support FROM settings"""
cursor.execute(sql_select_query)
order_volume = cursor.fetchone()[0]  # обьём
coef = '0'
data = (date, active_collector, title, order_number, order_volume, coef)
cursor.executemany(
        """INSERT INTO archive(Date,name,title,order_number,order_volume,coef) VALUES (?, ?, ?, ?, ?,?)""", (data,))
conn.commit()
print('Добавлено!')

当我再次按下按钮时，这个过程应该停止。

python

1 个回答

  1. Best Answer

    使用时间表，您可以创建工作。当不再需要该工作时，将其取消。我不知道按钮处理程序代码，所以我写了一般

    import time
import threading
import schedule
import queue


def set_support(active_collector):
    date = datetime.date.today()
    title = 'Помощь'
    order_number = '-'
    sql_select_query = """SELECT Support FROM settings"""
    cursor.execute(sql_select_query)
    order_volume = cursor.fetchone()[0]  # обьём
    coef = '0'
    data = (date, active_collector, title, order_number, order_volume, coef)
    cursor.executemany(
            """INSERT INTO archive(Date,name,title,order_number,order_volume,coef) VALUES (?, ?, ?, ?, ?,?)""", (data,))
    conn.commit()
    print('Добавлено!')


Mainjob = None
def run_scheduler(active_collector):
    Mainjob = schedule.every(10).minutes.do(set_support, active_collector = active_collector)
def off_scheduler():
    schedule.cancel_job(Mainjob)
    
def run_timer():
    while True:
        schedule.run_pending()
        time.sleep(1)

thread = Thread(target = run_timer)
thread.start()

    run_scheduler - 启动作业

    off_scheduler - 关闭工作

    • 0

相关问题