Skip to content

Instantly share code, notes, and snippets.

@tzununbekov
Created February 3, 2023 09:24
Show Gist options
  • Save tzununbekov/c19c68706004f92f354bfb2fce49b705 to your computer and use it in GitHub Desktop.
Save tzununbekov/c19c68706004f92f354bfb2fce49b705 to your computer and use it in GitHub Desktop.
Simple integration that reads messages from the AWS SQS queue and sends them to local Sockeye web-console. Can be deployed with `tmctl import` command.
---
apiVersion: eventing.triggermesh.io/v1alpha1
kind: RedisBroker
metadata:
labels:
triggermesh.io/context: foo
name: foo
---
apiVersion: v1
data:
accessKeyID: <user_input>
secretAccessKey: <user_input>
kind: Secret
metadata:
labels:
triggermesh.io/context: foo
name: foo-awssqssource-secret
type: Opaque
---
apiVersion: sources.triggermesh.io/v1alpha1
kind: AWSSQSSource
metadata:
labels:
triggermesh.io/context: foo
name: foo-awssqssource
spec:
arn: <user_input>
auth:
credentials:
accessKeyID:
valueFromSecret:
key: accessKeyID
name: foo-awssqssource-secret
secretAccessKey:
valueFromSecret:
key: secretAccessKey
name: foo-awssqssource-secret
sink:
ref:
apiVersion: eventing.triggermesh.io/v1alpha1
kind: RedisBroker
name: foo
---
apiVersion: serving.knative.dev/v1
kind: Service
metadata:
labels:
triggermesh.io/context: foo
triggermesh.io/role: target
name: sockeye
spec:
template:
spec:
containers:
- env: []
image: docker.io/n3wscott/sockeye:v0.7.0
name: user-container
---
apiVersion: flow.triggermesh.io/v1alpha1
kind: Transformation
metadata:
labels:
triggermesh.io/context: foo
name: foo-transformation
spec:
context:
- operation: add
paths:
- key: type
value: foo-transformation.output
data:
- operation: add
paths:
- key: new-field
value: hello from Transformation!
---
apiVersion: eventing.triggermesh.io/v1alpha1
kind: Trigger
metadata:
labels:
triggermesh.io/context: foo
name: foo-trigger-9dad7875
spec:
broker:
group: eventing.triggermesh.io
kind: RedisBroker
name: foo
filters:
- exact:
type: foo-transformation.output
target:
ref:
apiVersion: serving.knative.dev/v1
kind: Service
name: sockeye
---
apiVersion: eventing.triggermesh.io/v1alpha1
kind: Trigger
metadata:
labels:
triggermesh.io/context: foo
name: foo-trigger-2ae431ff
spec:
broker:
group: eventing.triggermesh.io
kind: RedisBroker
name: foo
filters:
- exact:
type: com.amazon.sqs.message
target:
ref:
apiVersion: flow.triggermesh.io/v1alpha1
kind: transformation
name: foo-transformation
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment