Redis队列使用Job-ID终止作业

Question

我使用了Python Flask+Redis，并使用以下代码将作业排入Redis队列：

with Connection(redis.from_url("redis://localhost:6379")):
queue = Queue()
task = queue.enqueue(self.redis_method, job_timeout=86400, result_ttl=604800, failure_ttl=604800)
response_object = {"status": "success", "data": {"task_id": task.get_id()}}
return response_object

作业正在排队并开始执行，我得到排队作业的作业id。并使用下面的代码杀死Job，但即使在执行下面的代码后，执行也不会停止

cancel_job(job_id=job_id,connection= redis.from_url("redis://localhost:6379"))

感谢您的帮助。提前感谢~

Answer 1

cancel_job从队列中删除作业。如果它已经在执行过程中，你必须杀死工人。

from rq.command import send_kill_horse_command
send_kill_horse_command(connection, worker_name)