Does anyone know if it's possible to access the new DynamoDB streams filtering using CDK? I.e. this I can't see reference to it in the docs for latest v1 or v2 but may be missing something.

lemme check if CDK has support for it

Thanks Frank, that's what I thought. Maybe it's time for me to learn how to build a custom construct

Here’s the CDK issue https://github.com/aws/aws-cdk/issues/17874

Thanks @Kujtim Hoxha I’m doing exactly that haha

Awesome

Aight @Ross Coundon here’s the workaround to update CFN directly

import { CfnResource } from "@aws-cdk/core";
import { CfnEventSourceMapping } from "@aws-cdk/aws-lambda";

// Create table
const table = new sst.Table(this, "Table", {
  ...,
  stream: true,
  consumers: {
    consumerA: "src/lambda.main",
  },
});

// The "AWS::Lambda::EventSourceMapping" is created as a child construct of "AWS::Lambda::Function", let's find it
const eventSource = table.getFunction("consumerA")?.node.children.find(
  child => (child.node.defaultChild as CfnResource)?.cfnResourceType === "AWS::Lambda::EventSourceMapping"
);

// Add filter to the CFN resource directly
const cfnEventSource = eventSource?.node.defaultChild as CfnEventSourceMapping;
cfnEventSource?.addPropertyOverride("FilterCriteria", {"Filters": [{"Pattern": "{ \"body\" : { \"age\": [ { \"numeric\": [ \"=\", 27 ] } ]}}"}]})

Wow, that was FAST!

Huge help for me here! Adding an example for filtering by PK/SK suffixes - useful if you are using overloaded indexes

Filters: [
  {
    Pattern: JSON.stringify({
      dynamodb: {
        Keys: {
          PK: { 
            S: [
              { prefix: "PK-prefix" }
            ]
          },
          SK: {
            S: [
              { prefix: "SK-prefix" }
            ]
          },
        },
      },
    }),
  },
]