aws-kinesisfirehose-s3-e-kinesisanalytics

Tutte le classi sono in fase di sviluppo attivo e soggette a modifiche o rimozione non compatibili con le versioni precedenti in qualsiasi versione futura. Questi non sono soggetti allaSemantic versioningModello. Ciò significa che, mentre è possibile utilizzarli, potrebbe essere necessario aggiornare il codice sorgente quando si esegue l'aggiornamento a una versione più recente di questo pacchetto.

Nota: Per garantire la corretta funzionalità, i pacchetti AWS Solutions Constructs e i pacchetti AWS CDK nel progetto devono essere della stessa versione.

Linguaggio	Pacchetto
Python	aws_solutions_constructs.aws_kinesisfirehose_s3_and_kinesisanalytics
TypeScript	@aws-solutions-constructs/aws-kinesisfirehose-s3-and-kinesisanalytics
Java	software.amazon.awsconstructs.services.kinesisfirehoses3kinesisanalytics

Overview

Questo AWS Solutions Construct implementa un flusso di consegna Amazon Kinesis Firehose collegato a un bucket Amazon S3 e un'applicazione Amazon Kinesis Analytics.

Ecco una definizione di modello distribuibile minima in 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);

Parametri

• scopeConstruct

• idstring

• propsKinesisFirehoseToAnalyticsAndS3Props

Puntelli di costruzione modelli

Nome	Tipo	Descrizione
KinesisFirehosepunps?	kinesisFirehose.CfnDeliveryStreamProps	Oggetti di scena opzionali forniti dall'utente per sovrascrivere gli oggetti di scena predefiniti per il flusso di erogazione Kinesis Firehose.
KinesisanalyticsProps?	kinesisAnalytics.CfnApplicationProps	Oggetti di scena facoltativi forniti dall'utente per sovrascrivere gli oggetti di scena predefiniti per l'applicazione Kinesis Analytics.
Esistente BucketObj?	s3.IBucket	Istanza esistente dell'oggetto S3 Bucket. Se questo è fornito, quindi anche fornirebucketPropsè un errore. |
Bucket Props?	s3.BucketProps	Proprietà facoltative fornite dall'utente per sovrascrivere le proprietà predefinite per il bucket. Ignorato se unexistingBucketObjviene fornito.
LogGroupProps?	logs.LogGroupProps	Elementi di scena facoltativi forniti dall'utente per sovrascrivere gli oggetti di scena predefiniti per il gruppo di log CloudWatch Logs.

Proprietà modelli

Nome	Tipo	Descrizione
Kinesisanalytics	kinesisAnalytics.CfnApplication	Restituisce un'istanza dell'applicazione Kinesis Analytics creata dal pattern.
KinesisFireHose	kinesisfirehose.CfnDeliveryStream	Restituisce un'istanza del flusso di consegna Kinesis Firehose creato dal pattern.
KinesisFireHoseLogGroup	logs.LogGroup	Restituisce un'istanza del gruppo di log creato dal modello a cui vengono inviati i log di accesso Kinesis Firehose.
KinesisFireHoserole	iam.Role	Restituisce un'istanza del ruolo IAM creato dal pattern per il flusso di consegna Kinesis Firehose.
S3Bucket?	s3.Bucket	Restituisce un'istanza del bucket S3 creato dalla serie.
S3loggingBucket?	s3.Bucket	Restituisce un'istanza del bucket di registrazione creato dal pattern per il bucket S3.

Impostazioni predefinite

L'implementazione predefinita di questo modello senza sostituzioni imposterà i seguenti valori predefiniti:

Amazon Kinesis Firehose

• Abilita la registrazione CloudWatch per Kinesis Firehose

• Configurare il ruolo IAM di accesso ai privilegi minimi per Amazon Kinesis Firehose

Amazon S3

• Configurare la registrazione degli accessi per S3

• Abilita la crittografia lato server per S3 Bucket utilizzando la chiave AWS gestita

• Attivare il controllo delle versioni per S3 Bucket

• Non consentire l'accesso pubblico per S3 Bucket

• Mantenere il bucket S3 quando si elimina lo stack CloudFormation

• Applicazione della crittografia dei dati in transito

• Applica la regola del ciclo di vita per spostare versioni degli oggetti non correnti nell'archivio Glacier dopo 90 giorni

Amazon Kinesis Data Analytics

• Configurare il ruolo IAM di accesso ai privilegi minimi per Amazon Kinesis Analytics

Architecture

GitHub

Per visualizzare il codice per questo modello, creare/visualizzare problemi e richieste pull e altro ancora:
	@aws -solutions-constructs/aws-kinesisfirehose-s3-and-kinesisanalytics