Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Lambda as Sink #4170

Closed
srikanthjg opened this issue Feb 21, 2024 · 0 comments · Fixed by #4292
Closed

Lambda as Sink #4170

srikanthjg opened this issue Feb 21, 2024 · 0 comments · Fixed by #4292
Assignees
Labels
enhancement New feature or request plugin - sink A plugin to write data to a destination.
Milestone

Comments

@srikanthjg
Copy link
Collaborator

srikanthjg commented Feb 21, 2024

Is your feature request related to a problem? Please describe.

Pipeline users want to send events to AWS Lambda.

Describe the solution you'd like
Create a new sink in Data Prepper which outputs data to lambda using codec. It should support

  • Retries
  • Different codecs
  • Buffering capabilities
  • DLQ

Without Batching:

lambda-pipeline:
...
  sink:
    - lambda:
        aws:
            region: us-east-1
            sts_role_arn: <arn>
            sts_overrides:
        function_name: "uploadToS3Lambda"
        max_retries: 3
        sync: False 
        dlq:
            s3:
                bucket: test-bucket
                key_path_prefix: dlq/

With Batching:

lambda-pipeline:
...
  sink:
    - lambda:
        aws:
            region: us-east-1
            sts_role_arn: <arn>
            sts_overrides:
        function_name: "uploadToS3Lambda"
        max_retries: 3
        batch:
            batch_key: "user_key"
            threshold:
                event_count: 3
                maximum_size: 6mb
                event_collect_timeout: 15s
        sync: False
        dlq:
            s3:
                bucket: test-bucket
                key_path_prefix: dlq/

Additional context
Add any other context or screenshots about the feature request here.

@github-project-automation github-project-automation bot moved this from Unplanned to Done in Data Prepper Tracking Board Jun 6, 2024
@dlvenable dlvenable added this to the v2.9 milestone Jun 7, 2024
@dlvenable dlvenable reopened this Jun 18, 2024
@github-project-automation github-project-automation bot moved this from In progress to To do in Data Prepper Tracking Board Jun 18, 2024
@github-project-automation github-project-automation bot moved this from Done to In progress in Data Prepper Tracking Board Jun 18, 2024
@dlvenable dlvenable added enhancement New feature or request plugin - sink A plugin to write data to a destination. and removed untriaged labels Jun 19, 2024
@dlvenable dlvenable modified the milestones: v2.9, v2.10 Aug 26, 2024
@dlvenable dlvenable modified the milestones: v2.10, v2.11 Oct 7, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request plugin - sink A plugin to write data to a destination.
Projects
Status: 2.11 (mid-Feb 2025)
Development

Successfully merging a pull request may close this issue.

3 participants