探索Django与Redis的完美结合：Django-RQ深度解析

from redis import Redis
from rq import Queue
from some_app.models import MyModel
from some_app.tasks import my_background_task
 
# 连接到Redis服务器
redis_conn = Redis(host='localhost', port=6379, db=0)
# 创建队列
queue = Queue(connection=redis_conn)
 
# 将任务添加到队列中
def enqueue_task():
    # 获取模型实例
    instance = MyModel.objects.get(id=1)
    # 将任务推送到队列中
    job = queue.enqueue(my_background_task, instance.id)
    return job.id
 
# 在后台运行的任务函数
def my_background_task(instance_id):
    # 获取模型实例
    instance = MyModel.objects.get(id=instance_id)
    # 执行一些耗时的操作...
    instance.do_something()
    instance.save()
 
# 调用函数来将任务加入到队列中
job_id = enqueue_task()
print(f"任务已加入队列，ID: {job_id}")

这个简单的代码示例展示了如何在Django应用中使用RQ（Redis Queue）来异步执行后台任务。首先，我们创建了一个连接到Redis服务器的连接对象，并用它初始化了一个RQ队列。然后，我们定义了一个将任务加入到队列中的函数，以及一个在后台运行的简单任务函数。最后，我们调用任务加入函数来演示如何操作。