Filter

class aws_cdk.aws_pipes_alpha.Filter(filter)

Bases: object

(experimental) The collection of event patterns used to filter events.

Stability:

experimental

ExampleMetadata:

infused

Example:

# source_queue: sqs.Queue
# target_queue: sqs.Queue


source_filter = pipes.Filter([
    pipes.FilterPattern.from_object({
        "body": {
            # only forward events with customerType B2B or B2C
            "customer_type": ["B2B", "B2C"]
        }
    })
])

pipe = pipes.Pipe(self, "Pipe",
    source=SqsSource(source_queue),
    target=SqsTarget(target_queue),
    filter=source_filter
)

Parameters:

filter (Sequence[IFilterPattern])

Stability:

experimental

Attributes

filters

(experimental) Filters for the source.

Stability:

experimental