sidekiq_enterprise20190828

Transcript

1. 4JEFLJR &OUFSQSJTFΛ ಋೖͯ͠ϝʔϧ഑৴+0#Λ վળͯ͠Έͨ࿩  !UBNBNVTIJ@ 1

2. 2 ⾃⼰紹介

3. 3 ⾃⼰紹介 ・川井⽥ 新介（かわいだ しんすけ） ・3年前まで⿅児島で農業したりしてた⼈ ・趣味はサウナ ・2019年1⽉メドピア⼊社 ・1⽉からRailsエンジニア

4. 4 今⽇のお話

5. 5 の前に

6. 6 Rails ばっちこいな⼈

7. 7 Sidekiq さわったことある⼈

8. 8 Sidekiqとは queue管理にRedisを使い マルチスレッドでメモリに優しい Rubyの⾮同期処理 フレームワーク

9. 9 有償版Pro・Enterprise

10. 10 Enterprise 導⼊の理由

11. 11 信頼性の向上 ・reliable_push ・super_fetch ・expiring_jobs

12. 12 Reliable Push(pro)
     ( ( )

13. 13 エンキュー！ 500 あいつどこ⾏った？ 普通のpush

14. 14 エンキュー！ 500 Reliable Push 隠し持ってたやつ エンキュー！ オッケー！

15. 15 Expiring Jobs(pro) 期 限 切 れ

16. 16 URL: https://github.com/mperham/sidekiq/wiki/Pro-Expiring-Jobs

17. 17 Super Fetch(pro)

18. 18 普通のfetch フェッチ ① ② ③ ④ ② ③ ④

19. 19 Super Fetch フェッチ ① ② ③ ④ ② ③

    ④ ① バックアップ

20. 20 今⽇のお話

21. 21 Sidekiq Enterpriseを導⼊して、 安⼼と信頼の定期実⾏ メール配信処理を実現した話

22. 22 を

23. 23 Sidekiq Enterpriseの 機能を紹介しながら していきます

24. 24 なので

25. 25 こんな気持ち ・Sidekiqの有償版きになるわぁ ・メール配信の定期実⾏って多重配信とかどう管 理してるのかしら ・普段Ruby触らないけど他⾔語の⾮同期処理でも 活かせるところあるかも で聞いていただけると嬉しいです。

26. 26 本題

27. 27 こんなJOBが ありました

28. 28 5分おきに実⾏ 1.配信待ちのメルマガを取得 2.送信中に更新 3.配信対象ユーザー分メール送信 4.送信結果を保存 5.送信完了に更新

29. 29 デプロイしたら死ぬ

30. 30 デプロイ時 ・キューのfetchを停⽌ ・8秒待ってプロセス終了 ・終わらなかったJOBは Redisに戻される

31. 31 再実⾏はされそう

32. 32 5分おきに実⾏ 1.配信待ちのメルマガを取得 2.送信中に更新 3.配信対象ユーザー分メール送信 4.送信結果を保存 5.送信完了に更新

33. 33 5分おきに実⾏ 1.配信待ちと送信中のメルマガを取得 2.送信中に更新!ココ

34. 34 5分おきに実⾏ 1.配信待ちと送信中のメルマガを取得 2.送信中に更新!ココ ステータスは送信中のままなので、 再実⾏時配信対象として取得されない

35. 35 送信中のメルマガも ひろうようにする

36. 36 5分おきに実⾏ 1.配信待ちと送信中!のメルマガを取得 2.送信中に更新 3.配信対象ユーザー分メール送信 4.送信結果を保存 5.送信完了に更新

37. 37 多重配信

38. 38 5分おきに実⾏ 1.配信待ちと送信中のメルマガを取得 !ココ 送信JOB① 送信JOB② メールA DB 送信中にするぜ 送信中のも送信するぜ

39. 39 ①ロックする 多重配信対策

40. 40 5分おきに実⾏ 1.配信待ちと送信中のメルマガを取得してロック 2.送信中に更新 3.配信対象ユーザー分メール送信 4.送信結果を保存 5.送信完了に更新

41. 41 5分おきに実⾏ 1.配信待ちと送信中のメルマガを取得 送信JOB① 送信JOB② メールA DB ロックして 送信中にするぜ ロックできない！！！

42. 42 そもそも実⾏時間 が⻑すぎる

43. 43 ②実⾏時間を短くする ためJOBを分ける 多重配信対策

44. 44 インポートJOB メール配信JOB

45. 45 5分おきに実⾏ 1.配信待ちと送信中のメルマガを取得してロック 2.送信中に更新 3.配信対象ユーザーをインポート 4.送信JOBをエンキュー インポートJOB

46. 46 1.メール送信 2.送信結果を保存 メール送信JOB

47. 47 インポートJOB メール配信JOB すべてのメール配信JOBが終了したら ステータスを更新したい

48. 48 Batches(Pro)

49. 49

50. 50 インポートJOB エンキューするJOB(Batches) メール配信JOB !

51. 51 インポートJOB エンキューするJOB(Batches) メール配信JOB リトライとかで 多重実⾏されないようにしたい

52. 52 Unique Jobs(Ent)

53. 53 指定した時間内に クラス名、引数、キューが 同じJOBを実⾏しないようにする

54. 54 なんとかなった

55. 55 学び ・設計から並列性、冪等性を 考慮した設計にしないとツライ

56. 56 Wiki のBest Practicesにも 書いてある url: https://github.com/mperham/sidekiq/wiki/Best-Practices

57. 57 でも

58. 58 元々の問題

59. 59 デプロイしたら死ぬ

60. 60 Rolling Restart(Ent)

61. 61 URL: https://github.com/mperham/sidekiq/wiki/Ent-Rolling-Restarts

62. 62 ※メモリに注意 ※新旧のコードに互換性が必要 新プロセス⽴ち上げて 旧プロセスのworkerの終了を 待ってから、旧プロセスを終了する

63. 63 学び ・設計から並列性、冪等性を 考慮した設計にしないとツライ ・Enterpriseだとなんとか してくれる機能がある

64. 64 ご清聴ありがとうございました！