2

我想创建一个适用于所有 10 分钟的工作。我在这里找到了一个很好的例子。问题是程序在等待期间冻结，我的其他 url 被阻止。在我之后是因为while True：

有没有办法在不解决这个问题的情况下做到这一点？

语音代码：

import schedule
import time

def job():
    print("I'm working...")

schedule.every(10).minutes.do(job)

while True:
    schedule.run_pending()
    time.sleep(1)

****************************************************** *****************。

我找到了正确的方法。这是链接：为了使其正常工作，我删除了这部分：

# time.sleep(20)
# print('Checkpoint **************************')
# time.sleep(30)
# print('Bye -----------------------')

这是有效的代码：

import threading
class ThreadingExample(object):
    """ Threading example class
    The run() method will be started and it will run in the background
    until the application exits.
    """

    def __init__(self, interval=10):
        """ Constructor
        :type interval: int
        :param interval: Check interval, in seconds
        """
        self.interval = interval

        thread = threading.Thread(target=self.run, args=())
        thread.daemon = True                            # Daemonize thread
        thread.start()                                  # Start the execution

    def run(self):
        """ Method that runs forever """
        while True:
            # Do something
            print('Doing something imporant in the background', self.interval)
            pk_info_semaine = job_temp.objects.all()
            for a in pk_info_semaine:
                print('num_semaine:',a.num_semaine,'user_id:',a.user_id)
            time.sleep(self.interval)

example = ThreadingExample()

谢谢大家，感谢作者：Paris Nakita Kejser Here

4

1 回答 1

3

您可以将 celery + celerybeat 与 Django 一起使用来运行计划任务。您可以将您的方法编写为 celery 任务，并在您的settings.py文件中添加一个条目以使该任务每 10 分钟运行一次。该任务将在其 on 线程中运行，因此不会阻塞您的应用程序。

芹菜的语音链接： http ://docs.celeryproject.org/en/latest/django/first-steps-with-django.html

于 2018-11-01T18:38:45.677 回答