rails-activejob

2热度

2回答

我想了解什么格式:at为ActiveJob是，这样我就可以使用assert_enqueued_with与:at参数。目前我已经有了这个测试，通过： tomorrow = 1.day.from_now.to_date assert_enqueued_with(job: ActionMailer::DeliveryJob) do onboarding.start_onboarding

2热度

1回答

使用ActiveJob，perform_now似乎有不同的结果比perform_later

我使用ActiveJob与SideKiq和下面的代码我使用perform_later比perform_now时得到不同的结果。当使用perform_now我的代码创建指定的文件夹和文件。当使用perform_later时，我可以看到代码执行并且不会被引入到Sidekiq的重试队列中，但不会创建文件夹或文件。如果还有其他事情可以帮助解决问题，请让我知道，因为我可能忽略了它。应用程序/控制器/

0热度

1回答

Rails的并发和activejobs

这里是ActiveJobs一些问题，我有：说我排队的作业n个经由ActiveJobs上sidekiq作业队列。在我的EC2上，我设置了4个工人，每个工作5个线程。这是否意味着多达20个并行作业将同时运行？当每个线程闲置并且处理它时，每个线程都会选择一个排队的作业吗？我尝试了这个设置，但它似乎仍然在一次处理串行 - 1个作业。我需要做更多的设置吗？关于并发性 - 我将如何能够设置更多的EC2实例

0热度

1回答

Rails ActiveJob SQS和记录在执行作业时仍然不存在

我正在使用SQS作为我的ActiveJobs的后端。我有被发送到队列中after_create回调我的模型的一个非常简单的工作： after_create :update_stuff_after_create 这初始化一个ActiveJob： UpdateStuffAfterCreateJob.perform_later(self.id) 将作业发送到SQS正确排队。问题是，其他实例谁是

0热度

1回答

创建一个始终运行的后台任务

我有一个只能用ruby发送的报文，执行bot我有一个运行我的ruby文件的二进制文件。最重要的部分是侦听来自用户的新消息。 Telegram::Bot::Client.run(token) do |bot| bot.listen do |message| call other methods here 但现在我想从这个简单的红宝石移动项目，对于Rails应用程序，因为我要开始开发更复杂的功

0热度

1回答

我怎样才能入队工作

我想入队任务 job = MyCustomJob.perform_later Job是MyCustomJob后访问我的ActiveRecord的工作项目后访问ActiveRecord的工作，但我怎么能没有做这样的事情Delayed::Job.last访问它？

1热度

3回答

如何从sidekiq获得工作执行时间？

每次我运行我的工作时，我都想知道执行时间。好像有一个宝石sidekiq-statistic，做什么，我想，甚至有GUI，但不幸的是我能得到从这些信息里莫名其妙地执行方法不与sidekiq 5.工作？我宁愿避免手工编写基准测试代码，我的方法包装成基准块

0热度

1回答

Sidekiq作业有效载荷的建议最大尺寸是多少？

工作有效载荷的建议最大尺寸是多少？作为一个具体的例子，是一个由500kb到1Mb的文本组成的HTML文档，它太大而无法传递给工作负载？由于Sidekiq支持redis，我会说512Mb，但我不知道Sidekiq方面是否有限制。

0热度

1回答

rubyzip在activejob中提取空文件

我在我的activejob中提供了一个从zip文件中提取特定文件的函数。以下代码提取空文件。 def extract_file(from, name) to = get_local_dest(name) Zip::File.open(from) do |zip_file| entry = zip_file.glob(name).first puts ent

2热度

1回答

与Sidekiq一起使用ActiveJob与Sidekiq相比的优势

我在线阅读一些教程，告诉我们使用ActiveJob和Sidekiq。但我不知道为什么我们应该这样做。我看到Sidekiq具有ActiveJob所具有的所有功能。此外，在Sidekiq文件：here 警告：通过做工作，通过ActiveJob重试，你失去了很多 Sidekiq功能：的Web UI可见性（在试片会空）您无法使用Sidekiq :: RetrySet API迭代重试。 Sidekiq