CfnApplicationReferenceDataSourcePropsMixin
- class aws_cdk.mixins_preview.aws_kinesisanalyticsv2.mixins.CfnApplicationReferenceDataSourcePropsMixin(props, *, strategy=None)
Bases:
MixinAdds 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:
- 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:
props (
Union[CfnApplicationReferenceDataSourceMixinProps,Dict[str,Any]]) – L1 properties to apply.strategy (
Optional[PropertyMergeStrategy]) – (experimental) Strategy for merging nested properties. Default: - PropertyMergeStrategy.MERGE
Methods
- apply_to(construct)
Apply the mixin properties to the construct.
- Parameters:
construct (
IConstruct)- Return type:
- 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
xis a Mixin.- Parameters:
x (
Any) – Any object.- Return type:
bool- Returns:
true if
xis an object created from a class which extendsMixin.- Stability:
experimental
CSVMappingParametersProperty
- class CfnApplicationReferenceDataSourcePropsMixin.CSVMappingParametersProperty(*, record_column_delimiter=None, record_row_delimiter=None)
Bases:
objectFor 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:
- 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.
- record_row_delimiter
The row delimiter.
For example, in a CSV format, ‘n’ is the typical row delimiter.
JSONMappingParametersProperty
- class CfnApplicationReferenceDataSourcePropsMixin.JSONMappingParametersProperty(*, record_row_path=None)
Bases:
objectFor 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:
- 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.
MappingParametersProperty
- class CfnApplicationReferenceDataSourcePropsMixin.MappingParametersProperty(*, csv_mapping_parameters=None, json_mapping_parameters=None)
Bases:
objectWhen 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:
- 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).
- json_mapping_parameters
Provides additional mapping information when JSON is the record format on the streaming source.
RecordColumnProperty
- class CfnApplicationReferenceDataSourcePropsMixin.RecordColumnProperty(*, mapping=None, name=None, sql_type=None)
Bases:
objectFor 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:
- 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.
- name
The name of the column that is created in the in-application input stream or reference table.
- sql_type
The type of column created in the in-application input stream or reference table.
RecordFormatProperty
- class CfnApplicationReferenceDataSourcePropsMixin.RecordFormatProperty(*, mapping_parameters=None, record_format_type=None)
Bases:
objectFor 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:
- 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.
ReferenceDataSourceProperty
- class CfnApplicationReferenceDataSourcePropsMixin.ReferenceDataSourceProperty(*, reference_schema=None, s3_reference_data_source=None, table_name=None)
Bases:
objectFor 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:
- 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.
- 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.
- table_name
The name of the in-application table to create.
ReferenceSchemaProperty
- class CfnApplicationReferenceDataSourcePropsMixin.ReferenceSchemaProperty(*, record_columns=None, record_encoding=None, record_format=None)
Bases:
objectFor 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 ofRecordColumnobjects.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:
- 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
RecordColumnobjects.
- record_encoding
Specifies the encoding of the records in the streaming source.
For example, UTF-8.
- record_format
Specifies the format of the records on the streaming source.
S3ReferenceDataSourceProperty
- class CfnApplicationReferenceDataSourcePropsMixin.S3ReferenceDataSourceProperty(*, bucket_arn=None, file_key=None)
Bases:
objectFor 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:
- 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.
- file_key
The object key name containing the reference data.