track.rb

# call
AmplitudeTracker.track(user.teespring_id, "should_send_notification", {
  type: "seller_variation_upsell"
})

# tracker
class AmplitudeTracker
  BASE_URL = "https://api.amplitude.com".freeze
  TRACK_URL = "/httpapi".freeze
  IDENTIFY_URL = "/identify".freeze

  def self.track(user_id, event_name, event_properties)
    AmplitudeWorker.perform_async(BASE_URL + TRACK_URL, {
      api_key: ENV['AMPLITUDE_API_KEY'],
      event: {
        event_type: event_name,
        user_id: user_id.to_s,
        event_properties: event_properties,
      }.to_json,
    })
  end

end

# worker
require 'typhoeus'

class AmplitudeWorker
  include Sidekiq::Worker

  def perform(url, properties)
    Typhoeus::Request.new(
      url,
      method: :get,
      params: properties,
    ).run
  end
end