Skip to content
This repository was archived by the owner on Dec 15, 2021. It is now read-only.

Commit 318980b

Browse files
author
Ahmed Ammar
committed
Add eventParser to store stream/scan.
1 parent f1c3b6a commit 318980b

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

lib/logstash/inputs/DynamoDBLogParser.rb

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,13 +65,15 @@ def parse_scan(log, new_image_size)
6565
@hash_template["dynamodb"]["sequenceNumber"] = "0"
6666
@hash_template["dynamodb"]["sizeBytes"] = size_bytes
6767
@hash_template["dynamodb"]["streamViewType"] = @view_type.upcase
68-
68+
@hash_template["eventParser"] = "scan"
6969
return parse_view_type(@hash_template)
7070
end
7171

7272
public
7373
def parse_stream(log)
74-
return parse_view_type(JSON.parse(@mapper.writeValueAsString(log))["internalObject"])
74+
data_hash = JSON.parse(@mapper.writeValueAsString(log))["internalObject"]
75+
data_hash["eventParser"] = "stream"
76+
return parse_view_type(data_hash)
7577
end
7678

7779
private

0 commit comments

Comments
 (0)