Rails apps (Main, Accounts) Microservices (Rails, Golang, Python) ? User/Profile service Main DB Read / Write GET / UPDATE on Kubernetes cluster Profile DB Read / Write
Rails apps (Main, Accounts) Microservices (Rails, Golang, Python) ? User/Profile service Main DB Read / Write on Kubernetes cluster Profile DB Read / Write GET / UPDATE
Rails apps (Main, Accounts) Microservices (Rails, Golang, Python) ? User/Profile service Main DB Read / Write GET / UPDATE on Kubernetes cluster Profile DB Read / Write "DUJWF3FDPSE͕͑ͳ͘ͳΔ ͜͜ͷҠߦ͕Ұ൪Ωπ͍
Rails apps (Main, Accounts) Microservices (Rails, Golang, Python) ? User/Profile service Main DB Read / Write on Kubernetes cluster Profile DB Read / Write GET / UPDATE ͍͖ͳΓཧΛٻΊΔͷݫ͍͠ʜ ஈ֊తʹҠߦͰ͖ͳ͍͔ʁ
has_many :working_histories end class WorkingHistory < ApplicationRecord belongs_to :company end class Company < ApplicationRecord end class Post < ApplicationRecord has_one :profile end
has_many :working_histories end class WorkingHistory < ApplicationRecord belongs_to :company end class Company < ApplicationRecord end class Post < ApplicationRecord has_one :profile end ย͍
has_many :working_histories end class WorkingHistory < ApplicationRecord belongs_to :company end class Company < ApplicationRecord end class Post < ApplicationRecord has_one :profile end ยΘΕ
has_many :working_histories end class WorkingHistory < ApplicationRecord belongs_to :company end class Company < ApplicationRecord end class Post < ApplicationRecord has_one :profile end ย͍ͷย͍
self.abstract_class = true db_config = YAML::load(ERB.new(IO.read('config/profile_database.yml')).result) establish_connection(db_config[Rails.env]) end class ProfileDb::Profile < ProfileDb::Base # ... end class ProfileDb::WorkingHistory < ProfileDb::Base # ... end "DUJWF3FDPSEͰଓઌΛม͑ΔΑ͋͘Δύλʔϯ
self.abstract_class = true db_config = YAML::load(ERB.new(IO.read('config/profile_database.yml')).result) establish_connection(db_config[Rails.env]) end class ProfileDb::Profile < ProfileDb::Base # ... end class ProfileDb::WorkingHistory < ProfileDb::Base # ... end ৽͘͠ϕʔεΫϥεΛ࡞ͬͯɼܧঝͤ͞Δ
self.abstract_class = true db_config = YAML::load(ERB.new(IO.read('config/profile_database.yml')).result) establish_connection(db_config[Rails.env]) end class ProfileDb::Profile < ProfileDb::Base # ... end class ProfileDb::WorkingHistory < ProfileDb::Base # ... end ϞδϡʔϧΛΔʁ
self.abstract_class = true db_config = YAML::load(ERB.new(IO.read('config/profile_database.yml')).result) establish_connection(db_config[Rails.env]) end class Profile < ProfileRecord # ... end class WorkingHistory < ProfileRecord # ... end ϞδϡʔϧΛΒͳ͍ʁ
ίʔυతʹʮҟͳΔυϝΠϯͰ͋Δ͜ͱͷද໌ʯ Ahas_manyAͷڍಈͱ͔ؾΛ͚ͭΔඞཁΞϦ ‣ Βͳ͍ʁ ϕʔεΫϥεม͑Δ͚ͩͳͷͰɼมߋ͘͢ͳ͍ ίʔυ্Ͱҧ͏%#Λࢀর͍ͯ͠Δ͜ͱ͕ෆ໌ྎ class ProfileDb::WorkingHistory < ProfileDb::Base # ... end # or class WorkingHistory < ProfileRecord # ... end
ίʔυతʹʮҟͳΔυϝΠϯͰ͋Δ͜ͱͷද໌ʯ Ahas_manyAͷڍಈͱ͔ؾΛ͚ͭΔඞཁΞϦ ‣ ࠓճΒͳ͍ʂ ϕʔεΫϥεม͑Δ͚ͩͳͷͰɼมߋ͘͢ͳ͍ ίʔυ্Ͱҧ͏%#Λࢀর͍ͯ͠Δ͜ͱ͕ෆ໌ྎ class ProfileDb::WorkingHistory < ProfileDb::Base # ... end # or class WorkingHistory < ProfileRecord # ... end
|c| !c.to_s.start_with?(Bundler.bundle_path.to_s) && c.to_s.start_with?(Rails.root.to_s) end info = { caller: caller_app || "", table: table.name, joins: flatten_recursively(joins_values), left_outer_joins: flatten_recursively(left_outer_joins_values), eager_load: flatten_recursively(eager_load_values), includes: flatten_recursively(includes_values), joined_includes: flatten_recursively(joined_includes_values), references_eager_loaded: flatten_recursively(references_eager_loaded_tables), request_controller: $request_controller, request_action: $request_action, } TD.event.post("join_queries", info) +0*/MPHHFS def flatten_recursively(arr) arr.flat_map do |i| case i when Hash then hash_to_array(i) when Array then flatten_recursively(i) when Arel::Nodes::Node then i.to_sql when ActiveRecord::Associations::JoinDependency then join_dependency_to_table_names(i) else i.to_s end end end def hash_to_array(h) h.keys + (h.values.flat_map { |v| case v when Hash then hash_to_array(v) when Array then flatten_recursively(v) when Arel::Nodes::Node then v.to_sql when ActiveRecord::Associations::JoinDependency then join_dependency_to_table_names(v) else v.to_s end }) end def join_dependency_to_table_names(jd) jd.aliases.instance_variable_get(:@tables).map { |a| a.table.table_name } end flatten_recursively IVNBOSFBEBCMFͳTUSJOHʹ͢ΔͨΊͷIFMQFS
base_tables, collect_set(t) as joined_tables_or_queries, collect_set(class) as classes, collect_set(request) as requests, collect_set(caller) as callers from ( select *, substring_index(caller, ':', 2) as caller_line, concat(request_controller, '#', request_action) as request from join_queries lateral view explode(joins) tmp as t where td_time_range(time, '2017-11-08 00:00:00', '2017-11-15 00:00:00') and ( ( table not in ('profiles', ..., 'working_histories', ...) and ( t = 'profile' or instr(t, 'profiles') != 0 -- ... or t = 'working_history' or instr(t, 'working_histories') != 0 -- ... ) ) or -- ... ) order by time desc ) queries group by caller_line ‣ ͬ͟ͱूܭ͢Δ DBMMFSͰHSPVQCZ +0*/ઌͱݩͷͲͪΒ͔͚ͩʹׂର͕ೖ͍ͬͯΔΫΤϦ ‣ ଟগࡶͰ0, ޡݕग़࠷ѱͳ͍ʢࣗͷνΣοΫର͕૿͑Δ͚ͩʣ ࿙Ε͕ແ͍Α͏ʹؾΛ͚ͭͯ42-ॻ͘
izumin5210
hypermkt
konokenj
kennethanceyer
taiyow
mackey0225
corocn
tsukkee
moshi1121
.png){kind=avatar}
oidy
irof
sgash708
zsmb
irinanazarova
maltzj
keathley
maggiecrowley
thoeni
jcasabona
aarron
bkeepers
jrom
sergeychernyshev
paigeccino
trallard
![©2018 Wantedly, Inc. DB splitting Ͳ͜·ͰΓग़͔͢ [2] pry(main)> Profile.methods.grep(/reflect/) =>](https://files.speakerdeck.com/presentations/ec373141a44942daabe3792ad2d5364e/slide_40.jpg){kind=link}
![©2018 Wantedly, Inc. DB splitting Ͳ͜·ͰΓग़͔͢ [1] pry(main)> Profile.methods.grep(/reflect/) =>](https://files.speakerdeck.com/presentations/ec373141a44942daabe3792ad2d5364e/slide_41.jpg){kind=link}
![©2018 Wantedly, Inc. DB splitting Ͳ͜·ͰΓग़͔͢ [2] pry(main)> Profile.reflect_on_all_associations.map(&:table_name).uniq =>](https://files.speakerdeck.com/presentations/ec373141a44942daabe3792ad2d5364e/slide_42.jpg){kind=link}
