Module: Jets::Job::Dsl::DynamodbEvent
- Defined in:
- lib/jets/job/dsl/dynamodb_event.rb
Instance Method Summary collapse
- #default_dynamodb_stream_policy(stream_name_arn = '*') ⇒ Object
- #dynamodb_event(table_name, options = {}) ⇒ Object
-
#full_dynamodb_stream_arn(table_name) ⇒ Object
Expands table name to the full stream arn.
Instance Method Details
#default_dynamodb_stream_policy(stream_name_arn = '*') ⇒ Object
47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
# File 'lib/jets/job/dsl/dynamodb_event.rb', line 47 def default_dynamodb_stream_policy(stream_name_arn='*') stream = { action: ["dynamodb:GetRecords", "dynamodb:GetShardIterator", "dynamodb:DescribeStream", "dynamodb:ListStreams"], effect: "Allow", resource: stream_name_arn, } table_name_arn = stream_name_arn.gsub(%r{/stream/20.*},'') table = { action: ["dynamodb:DescribeTable"], effect: "Allow", resource: table_name_arn, } [stream, table] end |
#dynamodb_event(table_name, options = {}) ⇒ Object
3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
# File 'lib/jets/job/dsl/dynamodb_event.rb', line 3 def dynamodb_event(table_name, ={}) stream_arn = full_dynamodb_stream_arn(table_name) default_iam_policy = default_dynamodb_stream_policy(stream_arn) # Create iam policy allows access to queue # Allow disabling in case use wants to add permission application-wide and not have extra IAM policy iam_policy_props = .delete(:iam_policy) || @iam_policy || default_iam_policy iam_policy(iam_policy_props) unless iam_policy_props == :disable props = # by this time options only has EventSourceMapping properties default = { event_source_arn: stream_arn, starting_position: "TRIM_HORIZON", } props = default.merge(props) event_source_mapping(props) end |
#full_dynamodb_stream_arn(table_name) ⇒ Object
Expands table name to the full stream arn. Example:
test-table
To:
arn:aws:dynamodb:us-west-2:112233445566:table/test-table/stream/2019-02-15T21:41:15.217
Note, this does not check if the stream has been disabled.
30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 |
# File 'lib/jets/job/dsl/dynamodb_event.rb', line 30 def full_dynamodb_stream_arn(table_name) return table_name if table_name.include?("arn:aws:dynamodb") # assume full stream arn begin resp = dynamodb.describe_table(table_name: table_name) rescue Aws::DynamoDB::Errors::ResourceNotFoundException => e puts e. puts "ERROR: Was not able to find the DynamoDB table: #{table_name}.".color(:red) code_line = caller.grep(%r{/app/jobs}).first puts "Please check: #{code_line}" puts "Exiting" exit 1 end stream_arn = resp.table.latest_stream_arn return stream_arn if stream_arn end |