Sha256: b7c1aecf4630273711a421fddbb6cb979bde59ea10acafd963e70a6ac2db6976
Contents?: true
Size: 268 Bytes
Versions: 139
Compression:
Stored size: 268 Bytes
Contents
require 'base64'
module Jets::Job::Helpers
module KinesisEventHelper
def kinesis_data
records = event["Records"]
records.map do |record|
encoded = record["kinesis"]["data"]
Base64.decode64(encoded) # data
end
end
end
end
Version data entries
139 entries across 139 versions & 3 rubygems