2017-09-19 162 views
0

我使用rails应用程序运行sidekiq。我需要能够从python脚本运行一个作业(因为我使用Luigi来运行一般任务)。我正在寻找一个Python库来处理Sidekiq API,但到目前为止还没有运气。对此有何想法或想法?使用python脚本调度sidekiq作业

谢谢!

回答

2

https://github.com/mperham/sidekiq/wiki/FAQ#how-do-i-push-a-job-to-sidekiq-without-ruby

这是最简单的红宝石,其转换到Python:

require 'securerandom' 
require 'json' 

redis = Redis.new(:url => 'redis://hostname:port/db') 
msg = { "class" => 'MyWorker', 
    "queue" => 'default', 
    "args" => [1, 2, 3], 
    'retry' => true, 
    'jid' => SecureRandom.hex(12), 
    'created_at' => Time.now.to_f, 
    'enqueued_at' => Time.now.to_f } 
redis.lpush("queue:default", JSON.dump(msg)) 
+0

感谢您的回答!我试过这个,但我仍然无法在sidekiq界面中看到它。我一直在寻找不同的方式将它发送到sidekiq可以看到的队列,但目前为止没有运气。 – gaba

+0

请参阅链接常见问题解答结尾的注释。 –

+0

在使用redis一段时间后,我能够使其工作。它帮助安装了一个可视化工具来查看redis。 – gaba