python-rq

    1熱度

    2回答

    我想改變rq工作的超時,但似乎沒有工作。我有東西的效果: my_queue = Queue('my_task', connection=Redis()) job_args = (1, 2, 4) my_queue.enqueue_call( my_func, args=job_args, timeout=2700 ) ,

    1熱度

    1回答

    我試圖輪詢以查看youtube-dl作業的狀態。我無法弄清楚如何使這個工作。 以下是我的python-RQ worker.py文件 class MyLogger(object): def debug(self, msg): pass def warning(self, msg): pass def error(self, msg):

    0熱度

    1回答

    我正在執行python-rq來傳遞隊列中的域名,並使用Beautiful Soup進行刮取。所以我正在運行多個工作人員來完成工作。截至目前,我開始了22名員工,所有22名員工都在rq儀表板中註冊。但過了一段時間後,工人自行停下來,並沒有顯示在儀表板中。但在webmin中,它顯示所有工作人員正在運行。爬行速度也下降,即工人沒有跑步。我試着用主管和nohup來運行這個工人。在這兩種情況下,工人自行停下

    2熱度

    1回答

    我正在構建一個使用Redis隊列的Flask應用程序。該工作人員的代碼是: listen = ['default'] #redis_url = os.getenv('REDISTOGO_URL', 'redis://localhost:6379') conn = redis.from_url(redis_url) if __name__ == '__main__': with C

    0熱度

    1回答

    目前RQ的日誌是這樣的: - 15:15:03 15:15:03 *** Listening on ingest... 15:17:41 ingest: tasks.ingest_job(aws_key='SDLKASFJHJKAHAJ', aws_secret='LDFKASJKDFJKSAHKJHkjsadhfkjaKJDSAHK') 所以,它記錄作業的論點太,這是一個安全問題,因爲參

    0熱度

    1回答

    我有當前的路線 @app.route('/as/<keyword>', methods=['GET']) @cache.memoize(timeout = 30 * 24 * 60 * 60) def auto_suggest(keyword): job = q.enqueue(find_keyword, keyword, timeout = 60 * 60) while

    0熱度

    1回答

    我正在嘗試在python-rq的工作任務內設置一個zmq套接字。 如果我創建context任務函數內部: def push(user, task_id, data): """Push message to `user` over websocket. """ ctx = zmq.Context() pub = ctx.socket(zmq.PUB)

    0熱度

    1回答

    我試圖在UWSGI中運行rqworker作爲附加的守護進程。要做到這一點,我添加到config.ini文件: attach-daemon = /path/to/rqworker 然後UWSGI嘗試當它應該推出rqworker但我得到在日誌中出現以下錯誤: RuntimeError: Click will abort further execution because Python 3 was

    0熱度

    4回答

    我試圖用RQ創建一個後臺作業: import django_rq def _send_password_reset_email_async(email): print(email) # Django admin action to send reset password emails

    2熱度

    1回答

    所有,我試圖'強迫'RQ工作人員使用supervisord同時執行。我的設置supervisord設置似乎工作正常,因爲rq-dashboard顯示3名工人,3個PID和3個隊列(每個工人/ PID一個)。 Supervisord設置如下(只顯示工作者1設置,2名工人被定義在這之下): [program:rqworker1] command = rqworker 1 process_name