wave I might be misunderstanding something but it seems lik Serverless Stack #help

:wave: I might be misunderstanding something but ...

Boris Tane

11/05/2021, 5:57 PM

👋 I might be misunderstanding something but it seems like the event bridge

addRules

function has lost some functionality. here we prevent setting up the

targets

https://github.com/serverless-stack/serverless-stack/blob/eed6864ee360edeac18312182bcd923ae9e87410/packages/resources/src/EventBus.ts#L19 but it means we cannot set the

RuleTargetInput

this is the CF reference for it https://docs.aws.amazon.com/eventbridge/latest/APIReference/API_PutTargets.html I'm basically trying to set InputTransformer
and InputPath
, any pointers? or should I revert to CF for this?

thdxr

11/05/2021, 5:59 PM

@Frank is most familiar with this construct so will let him respond

Frank

11/05/2021, 5:59 PM

taking a look..

Clayton

11/05/2021, 6:01 PM

Not certain if it’s the ideal way to add these props, but I think this format worked -

Copy code

new events.Rule(this, 'Event Lake Rule', {
      ruleName: 'event-lake-rule',
      enabled: true,
      eventBus: events.EventBus.fromEventBusName(this, 'SubSystem EventBus', subsystemEventBusName),
      eventPattern: { source: ['custom'] },
      targets: [
        new targets.KinesisFirehoseStream(deliveryStream, {
          message: events.RuleTargetInput.fromObject({
            id: 'EventLake',
            arn: deliveryStream.attrArn,
            roleArn: eventBridgeRole.roleArn,
            // Add EOL delimiter to aid parsing in CLI utility
            inputTransformer: {
              inputTemplate: '<aws.events.event>\n',
            },
          }),
        }),
      ],
    });

thdxr

11/05/2021, 6:03 PM

Yeah you can do it using normal CDK as a fallback, btw you don't have to import the bus, if you have a handle to

sst.EventBus

it has a field on it to get the underlying eventbus

Frank

11/05/2021, 6:03 PM

@Boris Tane, what target is this? Lambda function?

Boris Tane

11/05/2021, 6:04 PM

trying the above, thanks @Clayton

Boris Tane

11/05/2021, 6:04 PM

@Frank I'm sending to a sqs queue

Frank

11/05/2021, 6:06 PM

Expanding on @Clayton’s answer:

Copy code

const myQueue = new Queue(this, "MyQueue");

new EventBus(this, "Bus", {
  rules: {
    rule1: {
      eventPattern: { source: ["myevent"] },
      targets: [
        {
          queue: myQueue,
          targetProps: {
            message: events.RuleTargetInput.fromObject({
              id: 'EventLake',
              arn: deliveryStream.attrArn,
              roleArn: eventBridgeRole.roleArn,
              // Add EOL delimiter to aid parsing in CLI utility
              inputTransformer: {
                inputTemplate: '<aws.events.event>\n',
              },
            }),
          },
        },
      ],
    },
  },
});

Sione

11/05/2021, 6:13 PM

Ohh nicee. I've been just using the CDK construct but SST one looks cleaner and shorter, will probably switch to it. BTW here how to map dynamic path from eventbridge's props for example here, the

detail

Copy code

message: events.RuleTargetInput.fromEventPath('$.detail'),

Boris Tane

11/05/2021, 6:26 PM

works all good, thanks all 👍

3 Views

Open in Slack

Previous Next