前言
Allows identical sidekiq jobs to be processed with a single background call
上述引用自 sidekiq-grouping，能將多個同 queue 的 worker 整合成一個處理
說明
直接以情境舉例，假如要打 API 更新第三方庫存數量，由於更新商品數量有加也有減，因此先 grouped 起來，整合成一個 job 處理
實作
在 Gemfile 中加入該 sidekiq-grouping，範例可參考此 pr
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21# 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 輸入
1
2
3
4
5
6
7
8
9
10
11
12
13# 當 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
在 routes.rb 檔案中加入 require "sidekiq/grouping/web"
小結
蠻好上手的一個 Gem，在 GitHub 的範例也寫得淺顯易懂，連測試也有範例，這邊就不多加贅述
參考資料
鐵人賽文章連結：https://ithelp.ithome.com.tw/articles/10264578
medium 文章連結：https://link.medium.com/0SSdkIm2Mjb
本文同步發布於 小菜的 Blog https://riverye.com/
備註：之後文章修改更新，以個人部落格為主