ResultWriter

class aws_cdk.aws_stepfunctions.ResultWriter(*, bucket, prefix=None)

Bases: object

Configuration for writing Distributed Map state results to S3.

ExampleMetadata:

infused

Example:

import aws_cdk.aws_s3 as s3


# create a bucket
bucket = s3.Bucket(self, "Bucket")

distributed_map = sfn.DistributedMap(self, "Distributed Map State",
    item_reader=sfn.S3JsonItemReader(
        bucket=bucket,
        key="my-key.json"
    ),
    result_writer=sfn.ResultWriter(
        bucket=bucket,
        prefix="my-prefix"
    )
)
distributed_map.item_processor(sfn.Pass(self, "Pass State"))

Parameters:

• bucket (IBucket) – S3 Bucket in which to save Map Run results.

• prefix (Optional[str]) – S3 prefix in which to save Map Run results. Default: - No prefix

Methods

provide_policy_statements()

Compile policy statements to provide relevent permissions to the state machine.

Return type:

List[PolicyStatement]

render()

Render ResultWriter in ASL JSON format.

Return type:

Any

Attributes

bucket

S3 Bucket in which to save Map Run results.

prefix

S3 prefix in which to save Map Run results.

Default:

• No prefix