CfnApplicationReferenceDataSourcePropsMixin

class aws_cdk.mixins_preview.aws_kinesisanalyticsv2.mixins.CfnApplicationReferenceDataSourcePropsMixin(props, *, strategy=None)

Bases: Mixin

Adds a reference data source to an existing SQL-based Kinesis Data Analytics application.

Kinesis Data Analytics reads reference data (that is, an Amazon S3 object) and creates an in-application table within your application. In the request, you provide the source (S3 bucket name and object key name), name of the in-application table to create, and the necessary mapping information that describes how data in an Amazon S3 object maps to columns in the resulting in-application table.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kinesisanalyticsv2-applicationreferencedatasource.html

CloudformationResource:

AWS::KinesisAnalyticsV2::ApplicationReferenceDataSource

Mixin:

true

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk.mixins_preview import mixins
from aws_cdk.mixins_preview.aws_kinesisanalyticsv2 import mixins as kinesisanalyticsv2_mixins

cfn_application_reference_data_source_props_mixin = kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin(kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourceMixinProps(
    application_name="applicationName",
    reference_data_source=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.ReferenceDataSourceProperty(
        reference_schema=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.ReferenceSchemaProperty(
            record_columns=[kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.RecordColumnProperty(
                mapping="mapping",
                name="name",
                sql_type="sqlType"
            )],
            record_encoding="recordEncoding",
            record_format=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.RecordFormatProperty(
                mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.MappingParametersProperty(
                    csv_mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.CSVMappingParametersProperty(
                        record_column_delimiter="recordColumnDelimiter",
                        record_row_delimiter="recordRowDelimiter"
                    ),
                    json_mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.JSONMappingParametersProperty(
                        record_row_path="recordRowPath"
                    )
                ),
                record_format_type="recordFormatType"
            )
        ),
        s3_reference_data_source=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.S3ReferenceDataSourceProperty(
            bucket_arn="bucketArn",
            file_key="fileKey"
        ),
        table_name="tableName"
    )
),
    strategy=mixins.PropertyMergeStrategy.OVERRIDE
)

Create a mixin to apply properties to AWS::KinesisAnalyticsV2::ApplicationReferenceDataSource.

Parameters:

Methods

apply_to(construct)

Apply the mixin properties to the construct.

Parameters:

construct (IConstruct)

Return type:

IConstruct

supports(construct)

Check if this mixin supports the given construct.

Parameters:

construct (IConstruct)

Return type:

bool

Attributes

CFN_PROPERTY_KEYS = ['applicationName', 'referenceDataSource']

Static Methods

classmethod is_mixin(x)

(experimental) Checks if x is a Mixin.

Parameters:

x (Any) – Any object.

Return type:

bool

Returns:

true if x is an object created from a class which extends Mixin.

Stability:

experimental

CSVMappingParametersProperty

class CfnApplicationReferenceDataSourcePropsMixin.CSVMappingParametersProperty(*, record_column_delimiter=None, record_row_delimiter=None)

Bases: object

For a SQL-based Kinesis Data Analytics application, provides additional mapping information when the record format uses delimiters, such as CSV.

For example, the following sample records use CSV format, where the records use the ‘n’ as the row delimiter and a comma (“,”) as the column delimiter:

"name1", "address1"

"name2", "address2"

Parameters:
  • record_column_delimiter (Optional[str]) – The column delimiter. For example, in a CSV format, a comma (“,”) is the typical column delimiter.

  • record_row_delimiter (Optional[str]) – The row delimiter. For example, in a CSV format, ‘n’ is the typical row delimiter.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-csvmappingparameters.html

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk.mixins_preview.aws_kinesisanalyticsv2 import mixins as kinesisanalyticsv2_mixins

c_sVMapping_parameters_property = kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.CSVMappingParametersProperty(
    record_column_delimiter="recordColumnDelimiter",
    record_row_delimiter="recordRowDelimiter"
)

Attributes

record_column_delimiter

The column delimiter.

For example, in a CSV format, a comma (“,”) is the typical column delimiter.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-csvmappingparameters.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-csvmappingparameters-recordcolumndelimiter

record_row_delimiter

The row delimiter.

For example, in a CSV format, ‘n’ is the typical row delimiter.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-csvmappingparameters.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-csvmappingparameters-recordrowdelimiter

JSONMappingParametersProperty

class CfnApplicationReferenceDataSourcePropsMixin.JSONMappingParametersProperty(*, record_row_path=None)

Bases: object

For a SQL-based Kinesis Data Analytics application, provides additional mapping information when JSON is the record format on the streaming source.

Parameters:

record_row_path (Optional[str]) – The path to the top-level parent that contains the records.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-jsonmappingparameters.html

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk.mixins_preview.aws_kinesisanalyticsv2 import mixins as kinesisanalyticsv2_mixins

j_sONMapping_parameters_property = kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.JSONMappingParametersProperty(
    record_row_path="recordRowPath"
)

Attributes

record_row_path

The path to the top-level parent that contains the records.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-jsonmappingparameters.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-jsonmappingparameters-recordrowpath

MappingParametersProperty

class CfnApplicationReferenceDataSourcePropsMixin.MappingParametersProperty(*, csv_mapping_parameters=None, json_mapping_parameters=None)

Bases: object

When you configure a SQL-based Kinesis Data Analytics application’s input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.

Parameters:
  • csv_mapping_parameters (Union[IResolvable, CSVMappingParametersProperty, Dict[str, Any], None]) – Provides additional mapping information when the record format uses delimiters (for example, CSV).

  • json_mapping_parameters (Union[IResolvable, JSONMappingParametersProperty, Dict[str, Any], None]) – Provides additional mapping information when JSON is the record format on the streaming source.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-mappingparameters.html

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk.mixins_preview.aws_kinesisanalyticsv2 import mixins as kinesisanalyticsv2_mixins

mapping_parameters_property = kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.MappingParametersProperty(
    csv_mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.CSVMappingParametersProperty(
        record_column_delimiter="recordColumnDelimiter",
        record_row_delimiter="recordRowDelimiter"
    ),
    json_mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.JSONMappingParametersProperty(
        record_row_path="recordRowPath"
    )
)

Attributes

csv_mapping_parameters

Provides additional mapping information when the record format uses delimiters (for example, CSV).

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-mappingparameters.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-mappingparameters-csvmappingparameters

json_mapping_parameters

Provides additional mapping information when JSON is the record format on the streaming source.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-mappingparameters.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-mappingparameters-jsonmappingparameters

RecordColumnProperty

class CfnApplicationReferenceDataSourcePropsMixin.RecordColumnProperty(*, mapping=None, name=None, sql_type=None)

Bases: object

For a SQL-based Kinesis Data Analytics application, describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

Also used to describe the format of the reference data source.

Parameters:
  • mapping (Optional[str]) – A reference to the data element in the streaming input or the reference data source.

  • name (Optional[str]) – The name of the column that is created in the in-application input stream or reference table.

  • sql_type (Optional[str]) – The type of column created in the in-application input stream or reference table.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-recordcolumn.html

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk.mixins_preview.aws_kinesisanalyticsv2 import mixins as kinesisanalyticsv2_mixins

record_column_property = kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.RecordColumnProperty(
    mapping="mapping",
    name="name",
    sql_type="sqlType"
)

Attributes

mapping

A reference to the data element in the streaming input or the reference data source.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-recordcolumn.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-recordcolumn-mapping

name

The name of the column that is created in the in-application input stream or reference table.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-recordcolumn.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-recordcolumn-name

sql_type

The type of column created in the in-application input stream or reference table.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-recordcolumn.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-recordcolumn-sqltype

RecordFormatProperty

class CfnApplicationReferenceDataSourcePropsMixin.RecordFormatProperty(*, mapping_parameters=None, record_format_type=None)

Bases: object

For a SQL-based Kinesis Data Analytics application, describes the record format and relevant mapping information that should be applied to schematize the records on the stream.

Parameters:
  • mapping_parameters (Union[IResolvable, MappingParametersProperty, Dict[str, Any], None]) – When you configure application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.

  • record_format_type (Optional[str]) – The type of record format.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-recordformat.html

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk.mixins_preview.aws_kinesisanalyticsv2 import mixins as kinesisanalyticsv2_mixins

record_format_property = kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.RecordFormatProperty(
    mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.MappingParametersProperty(
        csv_mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.CSVMappingParametersProperty(
            record_column_delimiter="recordColumnDelimiter",
            record_row_delimiter="recordRowDelimiter"
        ),
        json_mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.JSONMappingParametersProperty(
            record_row_path="recordRowPath"
        )
    ),
    record_format_type="recordFormatType"
)

Attributes

mapping_parameters

When you configure application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-recordformat.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-recordformat-mappingparameters

record_format_type

The type of record format.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-recordformat.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-recordformat-recordformattype

ReferenceDataSourceProperty

class CfnApplicationReferenceDataSourcePropsMixin.ReferenceDataSourceProperty(*, reference_schema=None, s3_reference_data_source=None, table_name=None)

Bases: object

For a SQL-based Kinesis Data Analytics application, describes the reference data source by providing the source information (Amazon S3 bucket name and object key name), the resulting in-application table name that is created, and the necessary schema to map the data elements in the Amazon S3 object to the in-application table.

Parameters:
  • reference_schema (Union[IResolvable, ReferenceSchemaProperty, Dict[str, Any], None]) – Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

  • s3_reference_data_source (Union[IResolvable, S3ReferenceDataSourceProperty, Dict[str, Any], None]) – Identifies the S3 bucket and object that contains the reference data. A Kinesis Data Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.

  • table_name (Optional[str]) – The name of the in-application table to create.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-referencedatasource.html

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk.mixins_preview.aws_kinesisanalyticsv2 import mixins as kinesisanalyticsv2_mixins

reference_data_source_property = kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.ReferenceDataSourceProperty(
    reference_schema=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.ReferenceSchemaProperty(
        record_columns=[kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.RecordColumnProperty(
            mapping="mapping",
            name="name",
            sql_type="sqlType"
        )],
        record_encoding="recordEncoding",
        record_format=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.RecordFormatProperty(
            mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.MappingParametersProperty(
                csv_mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.CSVMappingParametersProperty(
                    record_column_delimiter="recordColumnDelimiter",
                    record_row_delimiter="recordRowDelimiter"
                ),
                json_mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.JSONMappingParametersProperty(
                    record_row_path="recordRowPath"
                )
            ),
            record_format_type="recordFormatType"
        )
    ),
    s3_reference_data_source=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.S3ReferenceDataSourceProperty(
        bucket_arn="bucketArn",
        file_key="fileKey"
    ),
    table_name="tableName"
)

Attributes

reference_schema

Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-referencedatasource.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-referencedatasource-referenceschema

s3_reference_data_source

Identifies the S3 bucket and object that contains the reference data.

A Kinesis Data Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-referencedatasource.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-referencedatasource-s3referencedatasource

table_name

The name of the in-application table to create.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-referencedatasource.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-referencedatasource-tablename

ReferenceSchemaProperty

class CfnApplicationReferenceDataSourcePropsMixin.ReferenceSchemaProperty(*, record_columns=None, record_encoding=None, record_format=None)

Bases: object

For a SQL-based Kinesis Data Analytics application, describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

Parameters:
  • record_columns (Union[IResolvable, Sequence[Union[IResolvable, RecordColumnProperty, Dict[str, Any]]], None]) – A list of RecordColumn objects.

  • record_encoding (Optional[str]) – Specifies the encoding of the records in the streaming source. For example, UTF-8.

  • record_format (Union[IResolvable, RecordFormatProperty, Dict[str, Any], None]) – Specifies the format of the records on the streaming source.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-referenceschema.html

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk.mixins_preview.aws_kinesisanalyticsv2 import mixins as kinesisanalyticsv2_mixins

reference_schema_property = kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.ReferenceSchemaProperty(
    record_columns=[kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.RecordColumnProperty(
        mapping="mapping",
        name="name",
        sql_type="sqlType"
    )],
    record_encoding="recordEncoding",
    record_format=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.RecordFormatProperty(
        mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.MappingParametersProperty(
            csv_mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.CSVMappingParametersProperty(
                record_column_delimiter="recordColumnDelimiter",
                record_row_delimiter="recordRowDelimiter"
            ),
            json_mapping_parameters=kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.JSONMappingParametersProperty(
                record_row_path="recordRowPath"
            )
        ),
        record_format_type="recordFormatType"
    )
)

Attributes

record_columns

A list of RecordColumn objects.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-referenceschema.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-referenceschema-recordcolumns

record_encoding

Specifies the encoding of the records in the streaming source.

For example, UTF-8.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-referenceschema.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-referenceschema-recordencoding

record_format

Specifies the format of the records on the streaming source.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-referenceschema.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-referenceschema-recordformat

S3ReferenceDataSourceProperty

class CfnApplicationReferenceDataSourcePropsMixin.S3ReferenceDataSourceProperty(*, bucket_arn=None, file_key=None)

Bases: object

For an SQL-based Amazon Kinesis Data Analytics application, identifies the Amazon S3 bucket and object that contains the reference data.

A Kinesis Data Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.

Parameters:
  • bucket_arn (Optional[str]) – The Amazon Resource Name (ARN) of the S3 bucket.

  • file_key (Optional[str]) – The object key name containing the reference data.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-s3referencedatasource.html

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk.mixins_preview.aws_kinesisanalyticsv2 import mixins as kinesisanalyticsv2_mixins

s3_reference_data_source_property = kinesisanalyticsv2_mixins.CfnApplicationReferenceDataSourcePropsMixin.S3ReferenceDataSourceProperty(
    bucket_arn="bucketArn",
    file_key="fileKey"
)

Attributes

bucket_arn

The Amazon Resource Name (ARN) of the S3 bucket.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-s3referencedatasource.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-s3referencedatasource-bucketarn

file_key

The object key name containing the reference data.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-applicationreferencedatasource-s3referencedatasource.html#cfn-kinesisanalyticsv2-applicationreferencedatasource-s3referencedatasource-filekey