Failed to create event: Aws::Kinesis::Errors::InternalFailure

after_create do |model|
  Eventable::Events::Create.create_event(model) if model.event_creation_on_create?
end

after_update do |model|
  Eventable::Events::Update.create_event(model) if model.event_creation_on_update?
end

after_destroy do |model|
  Eventable::Events::Delete.create_event(model) if model.event_creation_on_delete?
end

def create_event(model)
  return nil if invalid_event?(model)

  begin
    event = _create_event(model)
    reason = extract_reason(event, model)
    properties = build_properties(model)

    track_event(model, reason, properties)

    Cupix::EventService.publish_event([event])    # Kinesis 호출 지점
    Cupix::Event.publish(event.serializable_hash(stringify_nested_fields: false))
  rescue StandardError => e
    Cupix::Logger.error("Failed to create event: #{e.message}", function: __method__, class: self.name, model: model.class.to_s, id: model.id, event_params: model.event_params, error: e)
    raise e  # 예외를 re-raise하여 콜백 체인 중단
  else
    model.event_created!
    event
  end
end

def self.publish_event(events = [])
  return if events.blank?
  return if %w[development test].include?(Rails.env)
  return unless release_date_by(Rails.env)

  _event = events.first
  records = events.map do |event|
    {
      data: event.serializable_hash.to_json,
      partition_key: Current.request_id || SecureRandom.uuid
    }
  end

  case ::Cupix::Tesla.launch_mode
  when 'CUPIXWORKS'
    stream_name = "#{::Cupix::Tesla.tenant}-cupixworks-#{Rails.env}-EventStream"
  when 'CUPIXVISTA'
    stream_name = "#{::Cupix::Tesla.tenant}-cupixvista-#{Rails.env}-EventStream"
  else
    Cupix::Logger.error('Failed to publish event: stream is not defined', ...)
  end

  response = Cupix::Aws::Kinesis.put_records!({ stream_name: stream_name, records: records })
  # ...
rescue RestClient::Exception => e
  # RestClient 예외만 별도 처리. AWS SDK 예외는 catch하지 않음
  raise Cupix::Errors::System.new(code: 'SYS20000', reason: "Failed to publish event: #{e.message}")
end

def put_records!(opts = {})
  raise Cupix::Errors::Argument.new(code: 'ARG10001', reason: 'stream_name is blank') if opts[:stream_name].blank?
  raise Cupix::Errors::Argument.new(code: 'ARG10001', reason: 'records is blank') if opts[:records].blank?

  kinesis_client.put_records({
    stream_name: opts[:stream_name],
    records: opts[:records]
  })
rescue => e
  Cupix::Logger.error("Failed to put records: #{e.message}", class: self.name, function: __method__, stream_name: opts[:stream_name], record_count: opts[:records]&.size, record_sizes: opts[:records]&.map { |r| r[:data]&.bytesize })

  raise e
end

service:cupixworks-api "Failed to create event" "Aws::Kinesis::Errors::InternalFailure"

service:cupixworks-api "Kinesis" status:error

service:cupixworks-api "Aws::Kinesis::Errors::Http503Error" status:error

{
  "message": "Failed to create event: Aws::Kinesis::Errors::InternalFailure",
  "status": "error",
  "class": "Eventable::Events::Update",
  "function": "create_event",
  "error.msg": "Aws::Kinesis::Errors::InternalFailure",
  "model": "Pano",
  "host": "ip-10-1-16-213.eu-central-1.compute.internal",
  "environment": "production",
  "tenant": "cupix",
  "version": "production-eu-central-1-20260426T2216Z0-a4578cc0-cupixworks"
}

{
  "message": "Failed to put records: Aws::Kinesis::Errors::InternalFailure",
  "status": "error",
  "class": "Cupix::Aws::Kinesis",
  "function": "put_records!"
}

2026-04-27T15:27:47.670Z Eventable::Events::Update - Failed to create event: Aws::Kinesis::Errors::Http503Error
2026-04-27T15:27:47.669Z Cupix::Aws::Kinesis      - Failed to put records: Aws::Kinesis::Errors::Http503Error
2026-04-27T15:27:32.176Z Eventable::Events::Update - Failed to create event: Aws::Kinesis::Errors::Http503Error
2026-04-27T15:27:24.162Z Eventable::Events::Update - Failed to create event: Aws::Kinesis::Errors::Http503Error

service:cupixworks-worker status:error ("Kinesis" OR "InternalFailure" OR "create event")

service:cupixworks-api status:warn ("Kinesis" OR "create event" OR "event creation")

api/v1/jobs_controller.rb:13 (update)
  -> concerns/parameter/job.rb:55 (set_parameters)
    -> concerns/statable/job.rb:91 (state machine callback)
      -> workers/job_callback_worker.rb:10 (perform)
        -> concerns/jobable/capture.rb:32 (job_stopped_callback)
          -> models/concerns/eventable/events/base.rb:17 (create_event)
            -> lib/cupix/event_service.rb:43 (publish_event)
              -> lib/cupix/aws/kinesis.rb:9 (put_records!)

service:cupixworks-api "Failed to put records" status:error