Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# Layanan Terkelola untuk kode contoh API Apache Flink
Topik ini berisi contoh blok permintaan untuk Layanan Terkelola untuk tindakan Apache Flink.
Untuk menggunakan JSON sebagai input untuk tindakan dengan AWS Command Line Interface (AWS CLI), simpan permintaan dalam file JSON. Selanjutnya teruskan nama file ke dalam tindakan menggunakan parameter `--cli-input-json`.
Contoh berikut menunjukkan cara menggunakan file JSON dengan tindakan.
```
$ aws kinesisanalyticsv2 start-application --cli-input-json file://start.json
```
*Untuk informasi selengkapnya tentang menggunakan JSON dengan AWS CLI, lihat [Menghasilkan Kerangka CLI dan Parameter JSON Masukan CLI](https://docs.aws.amazon.com/cli/latest/userguide/generate-cli-skeleton.html) di Panduan Pengguna.AWS Command Line Interface *
**Topics**
+ [AddApplicationCloudWatchLoggingOption](#api-examples-addapplicationcloudwatchloggingoption)
+ [AddApplicationInput](#api-examples-addapplicationinput)
+ [AddApplicationInputProcessingConfiguration](#api-examples-addapplicationinputprocessingconfiguration)
+ [AddApplicationOutput](#api-examples-addapplicationoutput)
+ [AddApplicationReferenceDataSource](#api-examples-addapplicationreferencedatasource)
+ [AddApplicationVpcConfiguration](#api-examples-AddApplicationVpcConfiguration)
+ [CreateApplication](#api-examples-createapplication)
+ [CreateApplicationSnapshot](#api-examples-createapplicationsnapshot)
+ [DeleteApplication](#api-examples-deleteapplication)
+ [DeleteApplicationCloudWatchLoggingOption](#api-examples-deleteapplicationcloudwatchloggingoption)
+ [DeleteApplicationInputProcessingConfiguration](#api-examples-deleteapplicationinputprocessingconfiguration)
+ [DeleteApplicationOutput](#api-examples-deleteapplicationoutput)
+ [DeleteApplicationReferenceDataSource](#api-examples-deleteapplicationreferencedatasource)
+ [DeleteApplicationSnapshot](#api-examples-deleteapplicationsnapshot)
+ [DeleteApplicationVpcConfiguration](#api-examples-DeleteApplicationVpcConfiguration)
+ [DescribeApplication](#api-examples-describeapplication)
+ [DescribeApplicationSnapshot](#api-examples-describeapplicationsnapshot)
+ [DiscoverInputSchema](#api-examples-discoverinputschema)
+ [ListApplications](#api-examples-listapplications)
+ [ListApplicationSnapshots](#api-examples-listapplicationsnapshots)
+ [StartApplication](#api-examples-startapplication)
+ [StopApplication](#api-examples-stopapplication)
+ [UpdateApplication](#api-examples-updateapplication)
## AddApplicationCloudWatchLoggingOption
Contoh kode permintaan berikut untuk [AddApplicationCloudWatchLoggingOption](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_AddApplicationCloudWatchLoggingOption.html)tindakan menambahkan opsi CloudWatch pencatatan Amazon ke Layanan Terkelola untuk aplikasi 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
Contoh kode permintaan berikut untuk [AddApplicationInput](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_AddApplicationInput.html)tindakan menambahkan input aplikasi ke Layanan Terkelola untuk aplikasi 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
Contoh kode permintaan berikut untuk [AddApplicationInputProcessingConfiguration](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_AddApplicationInputProcessingConfiguration.html)tindakan menambahkan konfigurasi pemrosesan input aplikasi ke Layanan Terkelola untuk aplikasi Apache Flink:
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 2,
"InputId": "2.1",
"InputProcessingConfiguration": {
"InputLambdaProcessor": {
"ResourceARN": "arn:aws:lambda:us-east-1:012345678901:function:MyLambdaFunction"
}
}
}
```
## AddApplicationOutput
Contoh kode permintaan berikut untuk [AddApplicationOutput](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_AddApplicationOutput.html)tindakan menambahkan aliran data Kinesis sebagai output aplikasi ke Layanan Terkelola untuk aplikasi 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
Contoh kode permintaan berikut untuk [AddApplicationReferenceDataSource](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_AddApplicationReferenceDataSource.html)tindakan menambahkan sumber data referensi aplikasi CSV ke Layanan Terkelola untuk aplikasi 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:::amzn-s3-demo-bucket",
"FileKey": "TickerReference.csv"
},
"TableName": "string"
}
}
```
## AddApplicationVpcConfiguration
Kode permintaan contoh untuk tindakan [AddApplicationVpcConfiguration](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_AddApplicationVpcConfiguration.html) berikut menambahkan konfigurasi VPC ke aplikasi yang sudah ada.
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 9,
"VpcConfiguration": {
"SecurityGroupIds": [ "sg-0123456789abcdef0" ],
"SubnetIds": [ "subnet-0123456789abcdef0" ]
}
}
```
## CreateApplication
Contoh kode permintaan berikut untuk [CreateApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_CreateApplication.html)tindakan membuat Layanan Terkelola untuk aplikasi 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:::amzn-s3-demo-bucket",
"FileKey":"myflink.jar",
"ObjectVersion":"AbCdEfGhIjKlMnOpQrStUvWxYz12345"
}
},
"CodeContentType":"ZIPFILE"
},
"FlinkApplicationConfiguration":{
"ParallelismConfiguration":{
"ConfigurationType":"CUSTOM",
"Parallelism":2,
"ParallelismPerKPU":1,
"AutoScalingEnabled":true
}
}
}
}
```
## CreateApplicationSnapshot
Contoh kode permintaan berikut untuk [CreateApplicationSnapshot](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_CreateApplicationSnapshot.html)tindakan membuat snapshot dari status aplikasi:
```
{
"ApplicationName": "MyApplication",
"SnapshotName": "MySnapshot"
}
```
## DeleteApplication
Contoh kode permintaan berikut untuk [DeleteApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplication.html)tindakan menghapus Layanan Terkelola untuk aplikasi Apache Flink:
```
{"ApplicationName": "MyApplication",
"CreateTimestamp": 12345678912}
```
## DeleteApplicationCloudWatchLoggingOption
Contoh kode permintaan berikut untuk [DeleteApplicationCloudWatchLoggingOption](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplicationCloudWatchLoggingOption.html)tindakan menghapus opsi CloudWatch pencatatan Amazon dari Layanan Terkelola untuk aplikasi Apache Flink:
```
{
"ApplicationName": "MyApplication",
"CloudWatchLoggingOptionId": "3.1"
"CurrentApplicationVersionId": 3
}
```
## DeleteApplicationInputProcessingConfiguration
Contoh kode permintaan berikut untuk [DeleteApplicationInputProcessingConfiguration](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplicationInputProcessingConfiguration.html)tindakan menghapus konfigurasi pemrosesan input dari Layanan Terkelola untuk aplikasi Apache Flink:
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 4,
"InputId": "2.1"
}
```
## DeleteApplicationOutput
Contoh kode permintaan berikut untuk [DeleteApplicationOutput](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplicationOutput.html)tindakan menghapus output aplikasi dari Layanan Terkelola untuk aplikasi Apache Flink:
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 4,
"OutputId": "4.1"
}
```
## DeleteApplicationReferenceDataSource
Contoh kode permintaan berikut untuk [DeleteApplicationReferenceDataSource](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplicationReferenceDataSource.html)tindakan menghapus sumber data referensi aplikasi dari Layanan Terkelola untuk aplikasi Apache Flink:
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 5,
"ReferenceId": "5.1"
}
```
## DeleteApplicationSnapshot
Contoh kode permintaan berikut untuk [DeleteApplicationSnapshot](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplicationSnapshot.html)tindakan menghapus snapshot dari status aplikasi:
```
{
"ApplicationName": "MyApplication",
"SnapshotCreationTimestamp": 12345678912,
"SnapshotName": "MySnapshot"
}
```
## DeleteApplicationVpcConfiguration
Kode permintaan contoh untuk tindakan [DeleteApplicationVpcConfiguration](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_DeleteApplicationVpcConfiguration.html) berikut menghapus konfigurasi VPC yang ada dari aplikasi.
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 9,
"VpcConfigurationId": "1.1"
}
```
## DescribeApplication
Contoh kode permintaan berikut untuk [DescribeApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DescribeApplication.html)tindakan mengembalikan rincian tentang Layanan Terkelola untuk aplikasi Apache Flink:
```
{"ApplicationName": "MyApplication"}
```
## DescribeApplicationSnapshot
Contoh kode permintaan berikut untuk [DescribeApplicationSnapshot](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DescribeApplicationSnapshot.html)tindakan mengembalikan rincian tentang snapshot dari status aplikasi:
```
{
"ApplicationName": "MyApplication",
"SnapshotName": "MySnapshot"
}
```
## DiscoverInputSchema
Contoh kode permintaan berikut untuk [DiscoverInputSchema](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DiscoverInputSchema.html)tindakan menghasilkan skema dari sumber 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"
}
```
Contoh kode permintaan berikut untuk [DiscoverInputSchema](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DiscoverInputSchema.html)tindakan menghasilkan skema dari sumber referensi:
```
{
"S3Configuration": {
"BucketARN": "arn:aws:s3:::amzn-s3-demo-bucket",
"FileKey": "TickerReference.csv"
},
"ServiceExecutionRole": "arn:aws:iam::123456789123:role/myrole"
}
```
## ListApplications
Contoh kode permintaan berikut untuk [ListApplications](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_ListApplications.html)tindakan mengembalikan daftar Layanan Terkelola untuk aplikasi Apache Flink di akun Anda:
```
{
"ExclusiveStartApplicationName": "MyApplication",
"Limit": 50
}
```
## ListApplicationSnapshots
Contoh kode permintaan berikut untuk [ListApplicationSnapshots](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_ListApplicationSnapshots.html)tindakan mengembalikan daftar snapshot dari status aplikasi:
```
{"ApplicationName": "MyApplication",
"Limit": 50,
"NextToken": "aBcDeFgHiJkLmNoPqRsTuVwXyZ0123"
}
```
## StartApplication
Contoh kode permintaan berikut untuk [StartApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_StartApplication.html)tindakan memulai Layanan Terkelola untuk aplikasi Apache Flink, dan memuat status aplikasi dari snapshot terbaru (jika ada):
```
{
"ApplicationName": "MyApplication",
"RunConfiguration": {
"ApplicationRestoreConfiguration": {
"ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT"
}
}
}
```
## StopApplication
Contoh kode permintaan berikut untuk tindakan [API\$1STopApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_StopApplication.html) menghentikan Layanan Terkelola untuk aplikasi Apache Flink:
```
{"ApplicationName": "MyApplication"}
```
## UpdateApplication
Contoh kode permintaan berikut untuk [UpdateApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_UpdateApplication.html)tindakan memperbarui Layanan Terkelola untuk aplikasi Apache Flink untuk mengubah lokasi kode aplikasi:
```
{"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 1,
"ApplicationConfigurationUpdate": {
"ApplicationCodeConfigurationUpdate": {
"CodeContentTypeUpdate": "ZIPFILE",
"CodeContentUpdate": {
"S3ContentLocationUpdate": {
"BucketARNUpdate": "arn:aws:s3:::amzn-s3-demo-bucket",
"FileKeyUpdate": "my_new_code.zip",
"ObjectVersionUpdate": "2"
}
}
}
}
```