Dạo gần đây mình có khởi động lại project cá nhân để luyện tập tay nghề(Hàng dùng view mặc định của Ruby, không dùng framework JS tử tế cho frontend và dùng Bootstrap 5.3 làm giao diện thôi. Cũng tối cổ so với trend TailwindCSS với chỗ React và VueJS). Ý tưởng thì là 1 website chứa lyrics, tua nhạc và có metronome chạy theo đúng tempo bài hát. Cái mà mình lần trước có deploy với AWS AppRunner rồi nhưng chưa đưa video được.

Vấn đề

Trong quá trình làm thì mình có nảy ra thêm việc tích hợp 1 số tính năng bảng xếp hạng âm nhạc, thông tin nghệ sĩ,.... Nhưng với quá trình xếp hạng ấy cũng nảy ra vấn đề làm sao để đánh giá nghệ sĩ từ bài hát và album của họ?

Và một trong những giải pháp ở đây là đánh giá dựa trên lượt view bài hát và lượt view album. Các nghệ sĩ sẽ được đánh giá dựa theo tổng lượt view của tất cả các bài hát và tất cả các album.(Đây là giải pháp của mình. Thực tế có thể sẽ có khác)

Vì vậy trước tiên mình có db như này và đã triển khai ổn thoả:

OK, đã có lượt view của album và lượt view của bài hát. 2 dữ liệu này sẽ được refresh mỗi khi có 1 người dùng vào trang info của 1 album hay 1 bài hát nào đó.

Tuy nhiên, nếu cứ mỗi lượt view được add vào như vậy, dẫn đến albums_points và songs_points sẽ thay đổi realtime, dẫn đến mọi người khác nhau có thể sẽ nhìn bản xếp hạng ở những vị trí khác nhau(rất phù hợp với tính năng trending nhưng không phù hợp lắm với xếp hạng). Mình muốn bảng xếp hạng theo lượt view được cố định trong 1 tuần rồi có bảng xếp hạng mới.

Và để giải quyết thì mình quyết định chạy scheduled job để cập nhật hàng tuần. Đó là lý do động vào Sidekiq

Code

Gemfile

Trước tiên, ở Gemfile mình thêm sidekiq như sau

# Gemfile
# ...
# Use Sidekiq
gem 'sidekiq'
gem 'sidekiq-scheduler'

Sau đó chạy bundle update

docker-compose

  redis:
    image: redis
    ports:
      - "6379:6379"

  app:
    build: .
    command: bash -c "rm -f tmp/pids/server.pid && bundle exec rails assets:precompile && bundle exec rails s -p 3000 -b '0.0.0.0'"
    volumes:
      - .:/rails-lyrics-site
      - bundle:/usr/local/bundle
      - tmp-data:/rails-lyrics-site/tmp
      - public-data:/rails-lyrics-site/public
    ports:
      - "3000:3000"
    depends_on:
      - db
      - redis

  sidekiq:
    build: .
    command: bundle exec sidekiq
    volumes:
      - .:/rails-lyrics-site
    depends_on:
      - db
      - redis

sidekiq muốn hoạt động được phải phụ thuộc vào redis, và cũng cần được tách ra như 1 component riêng chạy song song song với phía container web nên ta thêm định nghĩa container:

  redis:
    image: redis
    ports:
      - "6379:6379"

và

  sidekiq:
    build: .
    command: bundle exec sidekiq
    volumes:
      - .:/rails-lyrics-site
    depends_on:
      - db
      - redis

Cuối cùng thêm container phụ thuộc ở app.

Setup phía config

Ta cần setup:

• Ở config/application.rb:

    config.active_job.queue_adapter = :sidekiq

• Tạo mới config/initializers/sidekiq.rb:

redis_config= { url: 'redis://redis:6379/0' }

Sidekiq.configure_server do |config|
  config.redis = redis_config
end

Sidekiq.configure_client do |config|
  config.redis = redis_config
end

• Thêm Sidekiq view ở config/routes.rb

# frozen_string_literal: true
require 'sidekiq/web'
require 'sidekiq-scheduler/web'

Rails.application.routes.draw do
  # ....

  mount Sidekiq::Web, at: '/sidekiq'
  match '*unmatched', to: 'application#not_found', via: :all
  # For details on the DSL available within this file, see https://guides.rubyonrails.org/routing.html
end

• Tạo mới config/sidekiq.yml:

:scheduler:
  :schedule:
    update_artist_pop_points:
      cron: '0 30 6 * * 1'
      class: ExampleJob

Bước cuối là start server lên kiểm tra localhost:3000/sidekiq. Khi hiện màn hình giống như này tức là các bạn thành công.

Tạo 1 job và chạy thử

Để tạo 1 Job trong Rails, chúng ta có command rails g job. Ví dụ, để tạo 1 Job có trên là Blo.....omJob, ta chạy rails g job bloom Ở tình huống này mình sẽ chạy:

rails g job UpdateArtistPopPointsJob

Ở app/jobs/update_artist_pop_points_job.rb, mình thêm code:

# frozen_string_literal: true

class UpdateArtistPopPointsJob < ApplicationJob
  queue_as :default

  def perform(*_args)
    # Do something later
    Artist.find_each do |artist|
      artist.songs_points = 0
      artist.albums_points = 0

      artist.albums.each do |album|
        artist.albums_points += album.views_count
      end

      artist.songs.each do |song|
        artist.songs_points += song.views_count
      end

      artist.save!
    end
  end
end

Chỉnh lại config/sidekiq.yml:

      class: UpdateArtistPopPointsJob

Các bạn có thể thấy là giờ Job của mình đã được lên ở trong Sidekiq và kích hoạt trong 6 ngày nữa. Mình có thể lựa chọn kích hoạt luôn.

Bonus: Authentication cho sidekiq

Rõ ràng trang kia thiên hướng về phía admin. Thế nên để chỉ admin xem được trang này, mình sẽ chỉnh ở routes:

  authenticate :user do
    mount Sidekiq::Web, at: '/sidekiq'
  end

Kết

Bài mình viết tới đây là hết