Ruby 脚本将 JSON 发送到 Sidekiq [已关闭]

ruby script send json to sidekiq [closed]

提问人:YasuoPlayer 提问时间:11/13/2023 更新时间:11/13/2023 访问量:48

问:


想改进这个问题吗?通过编辑这篇文章添加详细信息并澄清问题。

8天前关闭。

我制作了一个 Ruby 脚本,从 MySQL 获取数据并将它们发送到 mongoDB。 我想将这个脚本分为 2 部分,按 sidekiq 队列划分。 在从 MySQL 获取数据的脚本的第一部分中,我会将这些数据发送到 Sidekiq,Sidekiq 将它们发送到接收并保存在 mongoDB 上的脚本的第二部分。 我该怎么办? 我尝试使用以下代码将脚本的第二部分连接到 Sidekiq:

require "redis"
redis = Redis.new(host: "127.0.0.1", port: 6379)

它有效,但我不明白脚本的第一部分如何将数据发送到 Sidekiq。

Ruby Redis Sidekiq

评论

0赞 spickermann 11/14/2023
您是否阅读过 Sidekiq 的 GitHub 存储库中的入门?如何设置 Sidekiq 和创建后台作业究竟有什么不清楚的地方?
0赞 YasuoPlayer 11/14/2023
是的,我阅读了此文档。我做了一个后台工作,但我不明白两件事。第一个:如何将我的 ruby 脚本与此作业连接起来。第二个:当我使用文档的命令创建作业时,它会生成一个带有 class 和 def perform 的代码,(如文档),我是在这部分实现某些内容还是添加部分代码,还是不接触任何东西?
0赞 YasuoPlayer 11/14/2023
@spickermann我尝试修改作业但无法正常工作,我尝试运行 bundle exec sidekiq,使用 redis 连接运行脚本,但在 sidekiq webUI 中我什么也看不到
0赞 spickermann 11/14/2023
请分享:您的 Sidekiq 作业类的代码以及用于修改作业的代码。顺便说一句,不建议修改作业,而是创建一个新作业,并有一个 guard 子句,以便在特定条件为真时不运行该作业(如果旧作业不执行任何操作)。
0赞 YasuoPlayer 11/14/2023
这是我的 sidekiq 作业代码: '''class RubyJob include Sidekiq::Job def perform(*args) end end'''

答: 暂无答案