aws-cdk-lib.aws_stepfunctions.WriterConfig

WriterConfig Class

Configuration to format the output.

Source

aws-stepfunctions/lib/states/distributed-map/result-writer.ts

Type last changed

v2.190.0 · 17 Apr 2025

Example

import * as s3 from 'aws-cdk-lib/aws-s3';

// create a bucket
const bucket = new s3.Bucket(this, 'Bucket');

// create a WriterConfig

const distributedMap = new sfn.DistributedMap(this, 'Distributed Map State', {
  resultWriterV2: new sfn.ResultWriterV2({
    bucket: bucket,
    prefix: 'my-prefix',
    writerConfig: {
      outputType: sfn.OutputType.JSONL,
      transformation: sfn.Transformation.NONE,
    },
  })
});
distributedMap.itemProcessor(new sfn.Pass(this, 'Pass State'));

import aws_cdk.aws_s3 as s3


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

# create a WriterConfig

distributed_map = sfn.DistributedMap(self, "Distributed Map State",
    result_writer_v2=sfn.ResultWriterV2(
        bucket=bucket,
        prefix="my-prefix",
        writer_config={
            "output_type": sfn.OutputType.JSONL,
            "transformation": sfn.Transformation.NONE
        }
    )
)
distributed_map.item_processor(sfn.Pass(self, "Pass State"))

import software.amazon.awscdk.services.s3.*;


// create a bucket
Bucket bucket = new Bucket(this, "Bucket");

// create a WriterConfig

DistributedMap distributedMap = DistributedMap.Builder.create(this, "Distributed Map State")
        .resultWriterV2(ResultWriterV2.Builder.create()
                .bucket(bucket)
                .prefix("my-prefix")
                .writerConfig(Map.of(
                        "outputType", OutputType.JSONL,
                        "transformation", Transformation.NONE))
                .build())
        .build();
distributedMap.itemProcessor(new Pass(this, "Pass State"));

// Install: dotnet add package Amazon.CDK.Lib
using Amazon.CDK.AWS.S3;


// create a bucket
var bucket = new Bucket(this, "Bucket");

// create a WriterConfig

var distributedMap = new DistributedMap(this, "Distributed Map State", new DistributedMapProps {
    ResultWriterV2 = new ResultWriterV2(new ResultWriterV2Props {
        Bucket = bucket,
        Prefix = "my-prefix",
        WriterConfig = new Dictionary<string, object> {
            { "outputType", OutputType.JSONL },
            { "transformation", Transformation.NONE }
        }
    })
});
distributedMap.ItemProcessor(new Pass(this, "Pass State"));

// Install: go get github.com/aws/aws-cdk-go/awscdk/v2
import s3 "github.com/aws/aws-cdk-go/awscdk"


// create a bucket
bucket := s3.NewBucket(this, jsii.String("Bucket"))

// create a WriterConfig

distributedMap := sfn.NewDistributedMap(this, jsii.String("Distributed Map State"), &DistributedMapProps{
	ResultWriterV2: sfn.NewResultWriterV2(&ResultWriterV2Props{
		Bucket: bucket,
		Prefix: jsii.String("my-prefix"),
		WriterConfig: map[string]interface{}{
			"outputType": sfn.OutputType_JSONL,
			"transformation": sfn.Transformation_NONE,
		},
	}),
})
distributedMap.ItemProcessor(sfn.NewPass(this, jsii.String("Pass State")))

Initializer

new WriterConfig(props: WriterConfigProps)

WriterConfig(props: WriterConfigProps)

new WriterConfig(WriterConfigProps props)

new WriterConfig(WriterConfigProps props)

NewWriterConfig(Props WriterConfigProps)

Properties

outputTypeOutputTypeoutput_typeOutputTypeoutputTypeOutputTypeOutputTypeOutputTypeOutputTypeOutputTyperequired#

The format of the Output of the child workflow executions.

transformationTransformationtransformationTransformationtransformationTransformationTransformationTransformationTransformationTransformationrequired#

The transformation to be applied to the Output of the Child Workflow executions.