1. Tự động chuyển đổi connection giữa primary và replica database
Để sử dụng read-only database, bạn cần config middleware
cho phần tự động chuyển đổi connection.
Middleware tự động chuyển đổi connection cho phép ứng dụng của bạn chuyển đổi giữa primary và reploca database dựa trên các HTTP verb của request.
Ví dụ: nếu ứng dụng của bạn nhận được yêu cầu POST, PUT, DELETE hoặc PATCH, ứng dụng sẽ tự động ghi vào primary database. Và, đối với các yêu cầu như GET hoặc HEAD, ứng dụng sẽ đọc replica database.
Để config middleware cho bộ chuyển đổi tự động; uncomment hoặc thêm dòng sau vào file config:
config.active_record.database_selector = { delay: 2.seconds }
Với các request GET hoặc HEAD, rails sẽ chỉ connect đến primary database nếu request nằm trong khoảng thời gian tính từ request ghi cuối cùng; theo mặc định, nó sẽ là 2 giây. Ví dú: giây thứ 10 bạn nhận đc 1 request POST (request ghi), thì trong 2 giây tiếp theo, tất cả request đọc sẽ tự động được kết nối tới primary database, thay vì replica database. Bạn có quyền tự do thay đổi option delay
dựa theo infra structure.
2. Kết nối thủ công với primary và replica dabase
Để kết nối với primary hoặc replica database theo cách thủ công; rails cung cấp phương thức ActiveRecord :: Base.connected_to
.
Đôi khi, ứng dụng của bạn cần kết nối với primary hoặc replica database không phân biệt loại request. Trong những trường hợp như vậy, bạn có thể sử dụng phương thức connect_to
do ActiveRecord
cung cấp.
ActiveRecord::Base.connected_to(role: :writing) do
Person.first
end
3. Horizontal sharding
Horizontal sharding
là việc bạn chia nhỏ database của mình để giảm số rows
trên mỗi database server, nhưng duy trì cùng một schema trên các "sharding". Điều này thường được gọi là "multi-tenant" sharding.
API hỗ trợ horizontal sharding
trong Rails tương tự như API hỗ trợ multiple database.
production:
primary:
database: my_primary_database
adapter: mysql
primary_replica:
database: my_primary_database
adapter: mysql
replica: true
primary_shard_one:
database: my_primary_shard_one
adapter: mysql
primary_shard_one_replica:
database: my_primary_shard_one
adapter: mysql
replica: true
Models được kết nối với API connect_to thông qua shard key:
class ApplicationRecord < ActiveRecord::Base
self.abstract_class = true
connects_to shards: {
default: { writing: :primary, reading: :primary_replica },
shard_one: { writing: :primary_shard_one, reading: :primary_shard_one_replica }
}
end
Sau đó, các models có thể hoán đổi kết nối theo cách thủ công thông qua API connect_to. Nếu sử dụng sharding, cả role
và shard
phải được truyền:
ActiveRecord::Base.connected_to(role: :writing, shard: :default) do
@id = Person.create! # Creates a record in shard default
end
ActiveRecord::Base.connected_to(role: :writing, shard: :shard_one) do
Person.find(@id) # Can't find record, doesn't exist because it was created
# in the default shard
end
API horizontal sharding
cũng hỗ trợ replica database. Bạn có thể hoán đổi role
và shard
bằng API connect_to.
ActiveRecord::Base.connected_to(role: :reading, shard: :shard_one) do
Person.first # Lookup record from read replica of shard one
end
REFS: https://guides.rubyonrails.org/active_record_multiple_databases.html https://hackernoon.com/how-to-manage-multiple-databases-in-rails-6-ye6x3ypv