Day08 — Gem-sidekiq-grouping 允許單個 sidekiq 處理多個相似(一樣)的 jobs

前言

Allows identical sidekiq jobs to be processed with a single background call

上述引用自 sidekiq-grouping,能將多個同 queue 的 worker 整合成一個處理

說明

實作

# config/routes.rb
require "sidekiq/grouping/web"
---# app/worker/flush_worker.rb
class FlushWorker
include Sidekiq::Worker
sidekiq_options(
retry: false,
batch_flush_size: 5, # 當 Jobs 數量超過 5 個時,將合併作業
batch_flush_interval: 30, # 每 30 秒合併作業一次
batch_unique: true, # 同參數是否要 unique,無指定預設為 false
)
def perform(groups = nil)
puts "args: #{groups}"
puts "execute #{self.class}"
end
end

接著在 rails console 輸入

# 當 batch_unique: true
10.times { FlushWorker.perform_async(1) }
# args: [[1]]
# 當 batch_unique: false or 沒指定
10.times { FlushWorker.perform_async(1) }
# args: [[1], [1], [1], [1], [1]]
10.times { |t| FlushWorker.perform_async(t) }
# args: [[0], [1], [2], [3], [4]]
# args: [[5], [6], [7], [8], [9]]

batch_unique: true

batch_unique: false 或沒寫

Web UI

小結

參考資料

  1. sidekiq-grouping, 允許使用單個後台調用處理相同的sidekiq作業

鐵人賽文章連結:https://ithelp.ithome.com.tw/articles/10264578
medium 文章連結:https://link.medium.com/0SSdkIm2Mjb
本文同步發布於 小菜的 Blog https://riverye.com/

備註:之後文章修改更新,以個人部落格為主

大家好,我是被端走的小菜。以個人部落格更新為主:https://riverye.com/

大家好,我是被端走的小菜。以個人部落格更新為主:https://riverye.com/