Showing
1 changed file
with
6 additions
and
6 deletions
... | @@ -44,12 +44,12 @@ class S3EventSource(kappa.event_source.base.EventSource): | ... | @@ -44,12 +44,12 @@ class S3EventSource(kappa.event_source.base.EventSource): |
44 | 44 | ||
45 | # Add S3 key filters | 45 | # Add S3 key filters |
46 | if 'key_filters' in self._config: | 46 | if 'key_filters' in self._config: |
47 | - filters_spec = { 'Key' : { 'FilterRules' : [] } } | 47 | + filters_spec = { 'Key' : { 'FilterRules' : [] } } |
48 | - for filter in self._config['key_filters']: | 48 | + for filter in self._config['key_filters']: |
49 | - if 'type' in filter and 'value' in filter and filter['type'] in ('prefix', 'suffix'): | 49 | + if 'type' in filter and 'value' in filter and filter['type'] in ('prefix', 'suffix'): |
50 | - rule = { 'Name' : filter['type'], 'Value' : filter['value'] } | 50 | + rule = { 'Name' : filter['type'], 'Value' : filter['value'] } |
51 | - filters_spec['Key']['FilterRules'].append(rule) | 51 | + filters_spec['Key']['FilterRules'].append(rule) |
52 | - notification_spec['LambdaFunctionConfigurations'][0]['Filter'] = filters_spec | 52 | + notification_spec['LambdaFunctionConfigurations'][0]['Filter'] = filters_spec |
53 | 53 | ||
54 | try: | 54 | try: |
55 | response = self._s3.call( | 55 | response = self._s3.call( | ... | ... |
-
Please register or login to post a comment