CDK Snippets

kinesis_analytics.py

schema = aws_kinesisanalytics.CfnApplication.InputSchemaProperty(
    record_columns=[col1],
    record_format=aws_kinesisanalytics.CfnApplication.RecordFormatProperty(
        record_format_type="CSV",
        mapping_parameters=aws_kinesisanalytics.CfnApplication.MappingParametersProperty(
            csv_mapping_parameters=aws_kinesisanalytics.CfnApplication.CSVMappingParametersProperty(
                record_column_delimiter=";",
                record_row_delimiter="|"
            )
        )
    )
)