fix: restore compatibility with the new logstash 5.x events api

Fixes #20
lukewaite · Apr 21, 2017 · 9311c4f · 9311c4f
1 parent 7ebc26c
commit 9311c4f
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/logstash/inputs/cloudwatch_logs.rb b/lib/logstash/inputs/cloudwatch_logs.rb
@@ -124,9 +124,9 @@ def process_log(queue, log, stream)
 
     @codec.decode(log.message.to_str) do |event|
       event.set("@timestamp", parse_time(log.timestamp))
-      event["[cloudwatch][ingestion_time]"] = parse_time(log.ingestion_time)
-      event["[cloudwatch][log_group]"] = stream.arn.split(/:/)[6]
-      event["[cloudwatch][log_stream]"] = stream.log_stream_name
+      event.set("[cloudwatch][ingestion_time]", parse_time(log.ingestion_time))
+      event.set("[cloudwatch][log_group]", stream.arn.split(/:/)[6])
+      event.set("[cloudwatch][log_stream]", stream.log_stream_name)
       decorate(event)
 
       queue << event