diff --git a/app/jobs/uri_collection_job.rb b/app/jobs/uri_collection_job.rb index ae4b098e..620123db 100644 --- a/app/jobs/uri_collection_job.rb +++ b/app/jobs/uri_collection_job.rb @@ -38,10 +38,7 @@ class UriCollectionJob < PeriodicJob host_dimensions = { host: host } columns.each_key do |column| - time_start = Time.now columns[column] = AccessLog.where(**host_dimensions).distinct(column).pluck(column) - - puts "#{column}: #{Time.now - time_start}" end # Las URIs son la fuente de verdad de las visitas, porque son las @@ -54,58 +51,40 @@ class UriCollectionJob < PeriodicJob name = 'host|uri' dimensions = { host: host, uri: uri } - time_start = Time.now rollup(name, beginning, **dimensions) - puts "#{dimensions.values.join}: #{Time.now - time_start}" - - time_start = Time.now reduce_rollup(name, beginning, **dimensions) - puts "reduced: #{Time.now - time_start}" columns.each_pair do |column, values| # Obtener orígenes de visitas por host values.each do |value| - time_start = Time.now - column_name = "host|uri|#{column}" - dimensions[column] = value + column_dimensions = { host: host, uri: uri } + column_dimensions[column] = value - rollup(column_name, beginning, **dimensions) - puts "#{dimensions.values.join}: #{Time.now - time_start}" - - time_start = Time.now - reduce_rollup(column_name, beginning, **dimensions) - puts "reduced: #{Time.now - time_start}" + rollup(column_name, beginning, **column_dimensions) + reduce_rollup(column_name, beginning, **column_dimensions) end end end # Reducir todas las visitas a cantidad de visitas por host - time_start = Time.now square_rollup(name: 'host|uri', new_name: 'host', interval: starting_interval, dimensions: host_dimensions, beginning: beginning) - puts "#{host}: #{Time.now - time_start}" # Acumular por mes y año - time_start = Time.now reduce_rollup('host', beginning, **host_dimensions) - puts "reduced: #{Time.now - time_start}" columns.each_key do |column| - time_start = Time.now square_rollup(name: "host|uri|#{column}", new_name: "host|#{column}", interval: starting_interval, dimensions: host_dimensions, beginning: beginning) - puts "#{host} #{column}: #{Time.now - time_start}" - time_start = Time.now reduce_rollup("host|#{column}", beginning, **host_dimensions) - puts "reduced: #{Time.now - time_start}" end end