Amazon Managed Service untuk Apache Flink sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.

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 di Panduan Pengguna.AWS Command Line Interface

AddApplicationCloudWatchLoggingOption

Contoh kode permintaan berikut untuk AddApplicationCloudWatchLoggingOptiontindakan 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 AddApplicationInputtindakan 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 AddApplicationInputProcessingConfigurationtindakan 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 AddApplicationOutputtindakan 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 AddApplicationReferenceDataSourcetindakan 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 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 CreateApplicationtindakan 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 CreateApplicationSnapshottindakan membuat snapshot dari status aplikasi:

{
   "ApplicationName": "MyApplication",
   "SnapshotName": "MySnapshot"
}

DeleteApplication

Contoh kode permintaan berikut untuk DeleteApplicationtindakan menghapus Layanan Terkelola untuk aplikasi Apache Flink:

{"ApplicationName": "MyApplication",
"CreateTimestamp": 12345678912}

DeleteApplicationCloudWatchLoggingOption

Contoh kode permintaan berikut untuk DeleteApplicationCloudWatchLoggingOptiontindakan 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 DeleteApplicationInputProcessingConfigurationtindakan menghapus konfigurasi pemrosesan input dari Layanan Terkelola untuk aplikasi Apache Flink:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 4,
   "InputId": "2.1"
}

DeleteApplicationOutput

Contoh kode permintaan berikut untuk DeleteApplicationOutputtindakan menghapus output aplikasi dari Layanan Terkelola untuk aplikasi Apache Flink:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 4,
   "OutputId": "4.1"
}

DeleteApplicationReferenceDataSource

Contoh kode permintaan berikut untuk DeleteApplicationReferenceDataSourcetindakan 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 DeleteApplicationSnapshottindakan menghapus snapshot dari status aplikasi:

{
   "ApplicationName": "MyApplication",
   "SnapshotCreationTimestamp": 12345678912,
   "SnapshotName": "MySnapshot"
}

DeleteApplicationVpcConfiguration

Kode permintaan contoh untuk tindakan DeleteApplicationVpcConfiguration berikut menghapus konfigurasi VPC yang ada dari aplikasi.

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 9,
   "VpcConfigurationId": "1.1"
}
            

DescribeApplication

Contoh kode permintaan berikut untuk DescribeApplicationtindakan mengembalikan rincian tentang Layanan Terkelola untuk aplikasi Apache Flink:

{"ApplicationName": "MyApplication"}

DescribeApplicationSnapshot

Contoh kode permintaan berikut untuk DescribeApplicationSnapshottindakan mengembalikan rincian tentang snapshot dari status aplikasi:

{
   "ApplicationName": "MyApplication",
   "SnapshotName": "MySnapshot"
}

DiscoverInputSchema

Contoh kode permintaan berikut untuk DiscoverInputSchematindakan 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 DiscoverInputSchematindakan 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 ListApplicationstindakan mengembalikan daftar Layanan Terkelola untuk aplikasi Apache Flink di akun Anda:

{
   "ExclusiveStartApplicationName": "MyApplication",
   "Limit": 50
}

ListApplicationSnapshots

Contoh kode permintaan berikut untuk ListApplicationSnapshotstindakan mengembalikan daftar snapshot dari status aplikasi:

{"ApplicationName": "MyApplication",
   "Limit": 50,
   "NextToken": "aBcDeFgHiJkLmNoPqRsTuVwXyZ0123"
}

StartApplication

Contoh kode permintaan berikut untuk StartApplicationtindakan 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_STopApplication menghentikan Layanan Terkelola untuk aplikasi Apache Flink:

{"ApplicationName": "MyApplication"}

UpdateApplication

Contoh kode permintaan berikut untuk UpdateApplicationtindakan 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"
         }
      }
   }
}