Anteriormente, o Amazon Managed Service for Apache Flink era conhecido como Amazon Kinesis Data Analytics for Apache Flink.
As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.
Código de exemplo do Managed Service for Apache Flink API
Este tópico contém exemplos de blocos de solicitação para ações no Managed Service for Apache Flink.
Para usar o JSON como entrada para uma ação com o AWS Command Line Interface (AWS CLI), salve a solicitação em um arquivo JSON. Em seguida, passe o nome do arquivo para a ação usando o parâmetro --cli-input-json
.
O exemplo a seguir demonstra como usar um arquivo JSON com uma ação.
$ aws kinesisanalyticsv2 start-application --cli-input-json file://start.json
Para obter mais informações sobre como usar o JSON com o AWS CLI, consulte Gerar parâmetros JSON do esqueleto da CLI e da entrada da CLI no Guia do usuário.AWS Command Line Interface
Tópicos
- AddApplicationCloudWatchLoggingOption
- AddApplicationInput
- AddApplicationInputProcessingConfiguration
- AddApplicationOutput
- AddApplicationReferenceDataSource
- AddApplicationVpcConfiguration
- CreateApplication
- CreateApplicationSnapshot
- DeleteApplication
- DeleteApplicationCloudWatchLoggingOption
- DeleteApplicationInputProcessingConfiguration
- DeleteApplicationOutput
- DeleteApplicationReferenceDataSource
- DeleteApplicationSnapshot
- DeleteApplicationVpcConfiguration
- DescribeApplication
- DescribeApplicationSnapshot
- DiscoverInputSchema
- ListApplications
- ListApplicationSnapshots
- StartApplication
- StopApplication
- UpdateApplication
AddApplicationCloudWatchLoggingOption
O exemplo de código de solicitação a seguir para a AddApplicationCloudWatchLoggingOptionação adiciona uma opção de CloudWatch registro da Amazon a um aplicativo Managed Service for Apache Flink:
{ "ApplicationName": "MyApplication", "CloudWatchLoggingOption": { "LogStreamARN": "arn:aws:logs:us-east-1:123456789123:log-group:my-log-group:log-stream:My-LogStream" }, "CurrentApplicationVersionId": 2 }
AddApplicationInput
O exemplo de código de solicitação a seguir para a AddApplicationInputação adiciona uma entrada de aplicativo a um aplicativo Managed Service for Apache Flink:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 2, "Input": { "InputParallelism": { "Count": 2 }, "InputSchema": { "RecordColumns": [ { "Mapping": "$.TICKER", "Name": "TICKER_SYMBOL", "SqlType": "VARCHAR(50)" }, { "SqlType": "REAL", "Name": "PRICE", "Mapping": "$.PRICE" } ], "RecordEncoding": "UTF-8", "RecordFormat": { "MappingParameters": { "JSONMappingParameters": { "RecordRowPath": "$" } }, "RecordFormatType": "JSON" } }, "KinesisStreamsInput": { "ResourceARN": "arn:aws:kinesis:us-east-1:012345678901:stream/ExampleInputStream" } } }
AddApplicationInputProcessingConfiguration
O exemplo de código de solicitação a seguir para a AddApplicationInputProcessingConfigurationação adiciona uma configuração de processamento de entrada do aplicativo a um serviço gerenciado para o aplicativo Apache Flink:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 2, "InputId": "2.1", "InputProcessingConfiguration": { "InputLambdaProcessor": { "ResourceARN": "arn:aws:lambda:us-east-1:012345678901:function:MyLambdaFunction" } } }
AddApplicationOutput
O exemplo de código de solicitação a seguir para a AddApplicationOutputação adiciona um stream de dados do Kinesis como saída do aplicativo para um serviço gerenciado para o aplicativo Apache Flink:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 2, "Output": { "DestinationSchema": { "RecordFormatType": "JSON" }, "KinesisStreamsOutput": { "ResourceARN": "arn:aws:kinesis:us-east-1:012345678901:stream/ExampleOutputStream" }, "Name": "DESTINATION_SQL_STREAM" } }
AddApplicationReferenceDataSource
O exemplo de código de solicitação a seguir para a AddApplicationReferenceDataSourceação adiciona uma fonte de dados de referência do aplicativo CSV a um aplicativo Managed Service for Apache Flink:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 5, "ReferenceDataSource": { "ReferenceSchema": { "RecordColumns": [ { "Mapping": "$.TICKER", "Name": "TICKER", "SqlType": "VARCHAR(4)" }, { "Mapping": "$.COMPANYNAME", "Name": "COMPANY_NAME", "SqlType": "VARCHAR(40)" }, ], "RecordEncoding": "UTF-8", "RecordFormat": { "MappingParameters": { "CSVMappingParameters": { "RecordColumnDelimiter": " ", "RecordRowDelimiter": "\r\n" } }, "RecordFormatType": "CSV" } }, "S3ReferenceDataSource": { "BucketARN": "arn:aws:s3:::MyS3Bucket", "FileKey": "TickerReference.csv" }, "TableName": "string" } }
AddApplicationVpcConfiguration
O exemplo a seguir de código de solicitação para a AddApplicationVpcConfigurationação adiciona uma configuração de VPC a um aplicativo existente:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9, "VpcConfiguration": { "SecurityGroupIds": [ "sg-0123456789abcdef0" ], "SubnetIds": [ "subnet-0123456789abcdef0" ] } }
CreateApplication
O exemplo de código de solicitação a seguir para a CreateApplicationação cria um serviço gerenciado para o aplicativo Apache Flink:
{ "ApplicationName":"MyApplication", "ApplicationDescription":"My-Application-Description", "RuntimeEnvironment":"FLINK-1_15", "ServiceExecutionRole":"arn:aws:iam::123456789123:role/myrole", "CloudWatchLoggingOptions":[ { "LogStreamARN":"arn:aws:logs:us-east-1:123456789123:log-group:my-log-group:log-stream:My-LogStream" } ], "ApplicationConfiguration": { "EnvironmentProperties": {"PropertyGroups": [ {"PropertyGroupId": "ConsumerConfigProperties", "PropertyMap": {"aws.region": "us-east-1", "flink.stream.initpos": "LATEST"} }, {"PropertyGroupId": "ProducerConfigProperties", "PropertyMap": {"aws.region": "us-east-1"} }, ] }, "ApplicationCodeConfiguration":{ "CodeContent":{ "S3ContentLocation":{ "BucketARN":"arn:aws:s3:::mybucket", "FileKey":"myflink.jar", "ObjectVersion":"AbCdEfGhIjKlMnOpQrStUvWxYz12345" } }, "CodeContentType":"ZIPFILE" }, "FlinkApplicationConfiguration":{ "ParallelismConfiguration":{ "ConfigurationType":"CUSTOM", "Parallelism":2, "ParallelismPerKPU":1, "AutoScalingEnabled":true } } } }
CreateApplicationSnapshot
O exemplo de código de solicitação a seguir para a CreateApplicationSnapshotação cria um instantâneo do estado do aplicativo:
{ "ApplicationName": "MyApplication", "SnapshotName": "MySnapshot" }
DeleteApplication
O exemplo de código de solicitação a seguir para a DeleteApplicationação exclui um serviço gerenciado para o aplicativo Apache Flink:
{"ApplicationName": "MyApplication", "CreateTimestamp": 12345678912}
DeleteApplicationCloudWatchLoggingOption
O exemplo de código de solicitação a seguir para a DeleteApplicationCloudWatchLoggingOptionação exclui uma opção de CloudWatch registro da Amazon de um aplicativo Managed Service for Apache Flink:
{ "ApplicationName": "MyApplication", "CloudWatchLoggingOptionId": "3.1" "CurrentApplicationVersionId": 3 }
DeleteApplicationInputProcessingConfiguration
O exemplo de código de solicitação a seguir para a DeleteApplicationInputProcessingConfigurationação remove uma configuração de processamento de entrada de um aplicativo Managed Service for Apache Flink:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 4, "InputId": "2.1" }
DeleteApplicationOutput
O exemplo de código de solicitação a seguir para a DeleteApplicationOutputação remove a saída de um aplicativo do Managed Service for Apache Flink:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 4, "OutputId": "4.1" }
DeleteApplicationReferenceDataSource
O exemplo de código de solicitação a seguir para a DeleteApplicationReferenceDataSourceação remove uma fonte de dados de referência do aplicativo Managed Service for Apache Flink:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 5, "ReferenceId": "5.1" }
DeleteApplicationSnapshot
O exemplo de código de solicitação a seguir para a DeleteApplicationSnapshotação exclui um instantâneo do estado do aplicativo:
{ "ApplicationName": "MyApplication", "SnapshotCreationTimestamp": 12345678912, "SnapshotName": "MySnapshot" }
DeleteApplicationVpcConfiguration
O exemplo a seguir de código de solicitação para a DeleteApplicationVpcConfigurationação remove uma configuração de VPC existente de um aplicativo:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9, "VpcConfigurationId": "1.1" }
DescribeApplication
O exemplo de código de solicitação a seguir para a DescribeApplicationação retorna detalhes sobre um serviço gerenciado para o aplicativo Apache Flink:
{"ApplicationName": "MyApplication"}
DescribeApplicationSnapshot
O exemplo de código de solicitação a seguir para a DescribeApplicationSnapshotação retorna detalhes sobre um instantâneo do estado do aplicativo:
{ "ApplicationName": "MyApplication", "SnapshotName": "MySnapshot" }
DiscoverInputSchema
O exemplo de código de solicitação a seguir para a DiscoverInputSchemaação gera um esquema de uma fonte de streaming:
{ "InputProcessingConfiguration": { "InputLambdaProcessor": { "ResourceARN": "arn:aws:lambda:us-east-1:012345678901:function:MyLambdaFunction" } }, "InputStartingPositionConfiguration": { "InputStartingPosition": "NOW" }, "ResourceARN": "arn:aws:kinesis:us-east-1:012345678901:stream/ExampleInputStream", "S3Configuration": { "BucketARN": "string", "FileKey": "string" }, "ServiceExecutionRole": "string" }
O exemplo de código de solicitação a seguir para a DiscoverInputSchemaação gera um esquema de uma fonte de referência:
{ "S3Configuration": { "BucketARN": "arn:aws:s3:::mybucket", "FileKey": "TickerReference.csv" }, "ServiceExecutionRole": "arn:aws:iam::123456789123:role/myrole" }
ListApplications
O exemplo de código de solicitação a seguir para a ListApplicationsação retorna uma lista de serviços gerenciados para aplicativos Apache Flink em sua conta:
{ "ExclusiveStartApplicationName": "MyApplication", "Limit": 50 }
ListApplicationSnapshots
O exemplo de código de solicitação a seguir para a ListApplicationSnapshotsação retorna uma lista de instantâneos do estado do aplicativo:
{"ApplicationName": "MyApplication", "Limit": 50, "NextToken": "aBcDeFgHiJkLmNoPqRsTuVwXyZ0123" }
StartApplication
O exemplo de código de solicitação a seguir para a StartApplicationação inicia um aplicativo Managed Service for Apache Flink e carrega o estado do aplicativo a partir do snapshot mais recente (se houver):
{ "ApplicationName": "MyApplication", "RunConfiguration": { "ApplicationRestoreConfiguration": { "ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT" } } }
StopApplication
O exemplo a seguir, o código de solicitação para a StopApplication ação API_ interrompe um serviço gerenciado para o aplicativo Apache Flink:
{"ApplicationName": "MyApplication"}
UpdateApplication
O exemplo de código de solicitação a seguir para a UpdateApplicationação atualiza um aplicativo Managed Service for Apache Flink para alterar a localização do código do aplicativo:
{"ApplicationName": "MyApplication", "CurrentApplicationVersionId": 1, "ApplicationConfigurationUpdate": { "ApplicationCodeConfigurationUpdate": { "CodeContentTypeUpdate": "ZIPFILE", "CodeContentUpdate": { "S3ContentLocationUpdate": { "BucketARNUpdate": "
arn:aws:s3:::my_new_bucket
", "FileKeyUpdate": "my_new_code.zip
", "ObjectVersionUpdate": "2" } } } }