aws-kinesisfiremanse-s3-y-kinesisanalytics

Todas las clases están en desarrollo activo y están sujetas a cambios o eliminación no compatibles con versiones anteriores en cualquier versión futura. Éstos no están sujetos a laVersionado semánticoModelo. Esto significa que, aunque puede usarlos, es posible que necesite actualizar el código fuente cuando actualice a una versión más reciente de este paquete.

Nota: Para garantizar una funcionalidad adecuada, los paquetes de AWS Solutions Constructs y los paquetes CDK de AWS del proyecto deben tener la misma versión.

Idioma	Paquete
Python	aws_solutions_constructs.aws_kinesisfirehose_s3_and_kinesisanalytics
Mecanografía	@aws-solutions-constructs/aws-kinesisfirehose-s3-and-kinesisanalytics
Java	software.amazon.awsconstructs.services.kinesisfirehoses3kinesisanalytics

Overview

Este constructo de soluciones de AWS implementa una transmisión de entrega de Amazon Kinesis Firehose conectada a un bucket de Amazon S3 y una aplicación de Amazon Kinesis Analytics.

Aquí hay una definición mínima de patrón implementable en TypeScript:

import { KinesisFirehoseToAnalyticsAndS3 } from '@aws-solutions-constructs/aws-kinesisfirehose-s3-and-kinesisanalytics';

new KinesisFirehoseToAnalyticsAndS3(this, 'FirehoseToS3AndAnalyticsPattern', {
    kinesisAnalyticsProps: {
        inputs: [{
            inputSchema: {
                recordColumns: [{
                    name: 'ticker_symbol',
                    sqlType: 'VARCHAR(4)',
                    mapping: '$.ticker_symbol'
                }, {
                    name: 'sector',
                    sqlType: 'VARCHAR(16)',
                    mapping: '$.sector'
                }, {
                    name: 'change',
                    sqlType: 'REAL',
                    mapping: '$.change'
                }, {
                    name: 'price',
                    sqlType: 'REAL',
                    mapping: '$.price'
                }],
                recordFormat: {
                    recordFormatType: 'JSON'
                },
                recordEncoding: 'UTF-8'
            },
            namePrefix: 'SOURCE_SQL_STREAM'
        }]
    }
});

Initializer

new KinesisFirehoseToAnalyticsAndS3(scope: Construct, id: string, props: KinesisFirehoseToAnalyticsAndS3Props);

Parámetros

• scopeConstruct

• idstring

• propsKinesisFirehoseToAnalyticsAndS3Props

Patrón de construcción

Nombre	Tipo	Descripción
¿KinesisFireHoseProps?	kinesisFirehose.CfnDeliveryStreamProps	Props opcionales proporcionados por el usuario para anular los accesorios predeterminados para la transmisión de entrega de Kinesis Firehose.
KinesisanalyticsProps?	kinesisAnalytics.CfnApplicationProps	Props opcionales proporcionados por el usuario para anular los accesorios predeterminados para la aplicación Kinesis Analytics.
¿ExistenteBuckeTobj?	s3.IBucket	Instancia existente del objeto S3 Bucket. Si se proporciona esto, entonces también proporcionabucketPropses un error. |
¿BucketProps?	s3.BucketProps	Propiedades opcionales proporcionadas por el usuario para anular las propiedades predeterminadas del depósito. Se pasa por alto si unexistingBucketObjse encuentra.
LogGroupProps?	logs.LogGroupProps	Proporcionadas por el usuario opcionales para anular los accesorios predeterminados para el grupo de registros de CloudWatch Logs.

Propiedades de patrón

Nombre	Tipo	Descripción
Kinesisanalytics	kinesisAnalytics.CfnApplication	Devuelve una instancia de la aplicación Kinesis Analytics creada por el patrón.
KinesisFirehose	kinesisfirehose.CfnDeliveryStream	Devuelve una instancia de la secuencia de entrega de Kinesis Firehose creada por el patrón.
KinesisFireHoselogGroup	logs.LogGroup	Devuelve una instancia del grupo de registros creado por el patrón al que se envían los registros de acceso de Kinesis Firehose.
KinesisFireHoserole	iam.Role	Devuelve una instancia del rol de IAM creado por el patrón para la secuencia de entrega de Kinesis Firehose.
¿S3 Bucket?	s3.Bucket	Devuelve una instancia del bucket S3 creado por el patrón.
¿S3LoggingBucket?	s3.Bucket	Devuelve una instancia del depósito de registro creado por el patrón para el bucket S3.

Configuración predeterminada

La implementación lista para usar de este patrón sin anulación establecerá los siguientes valores predeterminados:

Amazon Kinesis Firehose

• Habilitar el registro de CloudWatch para Kinesis Firehose

• Configurar el rol de IAM de acceso mínimo con privilegios para Amazon Kinesis Firehose

Bucket de Amazon S3

• Configurar el registro de acceso para S3 Bucket

• Habilitar el cifrado del lado del servidor para S3 Bucket utilizando la clave KMS administrada por AWS

• Activar el control de versiones para S3 Bucket

• No permitir el acceso público para S3 Bucket

• Conservar el depósito de S3 al eliminar la pila de CloudFormation

• Aplicación del cifrado de los datos en tránsito

• Aplica una regla de ciclo de vida para mover versiones de objetos no actuales al almacenamiento de Glacier después de 90 días

Amazon Kinesis Data Analytics

• Configurar el rol de IAM de acceso mínimo con privilegios para Amazon Kinesis Analytics

Architecture

GitHub

Para ver el código de este patrón, crear/ver problemas y solicitudes de extracción, y mucho más:
	@aws -soluciones-constructs/aws-kinesisfiremanse-s3-y-kinesisanalytics