Heroku上的红星没有回应

Question

我对Redis排队的工作任务很陌生。我试图在队列中使用Redis来添加一些功能。但是，在我把一些任务推到队列上之后，它似乎消失了。

这是我的密码

import Flask
import redis
from rq import Queue

REDIS_URL = os.getenv('REDISTOGO_URL', None)
if REDIS_URL!=None:
    r = redis.from_url(REDIS_URL)
else:
    r = redis.Redis()

q = Queue(connection=r)

def function(pam1):
    print("Checkpoint1")
    return 0

@main.route('/name', methods=['GET', 'POST'])
def displayname():
    job = q.enqueue(function, pam1=0)
    return job.id

队列上的其他信息:仍然提供作业id，如7344337b-cca0-442a-b43a- the dc88f012c。

但在heroku日志上根本没有"Checkpoint1“的迹象。

Answer 1

感谢@v25。Redis之所以没有回应的真正原因是因为我没有员工。拿到清华参见Heroku关于启动工人的指南后，我的问题就解决了。

Answer 2

我不确定Heroku的日志实现，但假设您查看了错误的日志(或其他什么)，您可以尝试这样做.

与打印“检查点”相反，增加自定义redis键的值：

def function(pam1):
    r.incr('job_ran', 1)
    return 0

然后创建一个可以检查此值的路由：

@app.route('/show_count')
def show_count():
    n = r.get('job_ran')

    if n is None:
        n = 0
    else:
        n = n.decode('utf-8')

    return f'Job has run {n} times'

现在，为几个作业排队，并检查/show_count路由，以确保它相应地递增。