use rails insert all

imfantuan · Mar 24, 2021 · 49e5941 · 49e5941
1 parent c7fb448
commit 49e5941
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/app/jobs/event_job.rb b/app/jobs/event_job.rb
@@ -8,12 +8,7 @@ class EventJob
   def perform(*args)
     Thread.current[:bq] ||= BufferQueue.new(max_batch_size: (ENV["MAX_BATCH_SIZE"] || 100).to_i, execution_interval: (ENV["EXECUTION_INTERVAL"] || 1).to_i) do |batch|
       puts "bulk insert #{batch.size} records"
-      Hyper::Event.import(
-        EventJob::COLUMN_NAMES,
-        batch.flatten.map { |attr| Hyper::Event.new(attr) },
-        validate: false,
-        timestamps: false
-      ) unless batch.empty?
+      Hyper::Event.insert_all!(batch)
     end
     params, form, request = args