Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per Apache Flink.

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Codice di esempio dell'API Managed Service per Apache Flink

Questo argomento contiene esempi di blocchi di richiesta per le operazioni del servizio gestito per Apache Flink.

Per utilizzare JSON come input per un'azione con AWS Command Line Interface (AWS CLI), salvate la richiesta in un file JSON. Passa quindi il nome del file nell'operazione utilizzando il parametro --cli-input-json.

L'esempio seguente mostra come utilizzare un file JSON con un'operazione.

$ aws kinesisanalyticsv2 start-application --cli-input-json file://start.json

Per ulteriori informazioni sull'utilizzo di JSON con AWS CLI, consulta Generate CLI Skeleton e CLI Input JSON Parameters nella Guida per l'utente.AWS Command Line Interface

AddApplicationCloudWatchLoggingOption

Il seguente codice di richiesta di esempio per l'AddApplicationCloudWatchLoggingOptionazione aggiunge un'opzione di CloudWatch registrazione Amazon a un'applicazione 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

Il seguente codice di richiesta di esempio per l'AddApplicationInputazione aggiunge un input dell'applicazione a un'applicazione 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

Il seguente codice di richiesta di esempio per l'AddApplicationInputProcessingConfigurationazione aggiunge una configurazione di elaborazione dell'input dell'applicazione a un'applicazione Managed Service for Apache Flink:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 2,
   "InputId": "2.1",
   "InputProcessingConfiguration": { 
      "InputLambdaProcessor": { 
         "ResourceARN": "arn:aws:lambda:us-east-1:012345678901:function:MyLambdaFunction"
      }
   }
}

AddApplicationOutput

Il seguente codice di richiesta di esempio per l'AddApplicationOutputazione aggiunge un flusso di dati Kinesis come output dell'applicazione a un'applicazione Managed Service for 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

Il seguente codice di richiesta di esempio per l'AddApplicationReferenceDataSourceazione aggiunge un'origine di dati di riferimento dell'applicazione CSV a un'applicazione 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:::amzn-s3-demo-bucket",
         "FileKey": "TickerReference.csv"
      },
      "TableName": "string"
   }
}

AddApplicationVpcConfiguration

Il seguente codice di richiesta di esempio per l'azione AddApplicationVpcConfiguration aggiunge una configurazione VPC a un'applicazione esistente:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 9,
   "VpcConfiguration": { 
      "SecurityGroupIds": [ "sg-0123456789abcdef0" ],
      "SubnetIds": [ "subnet-0123456789abcdef0" ]
   }
}
            

CreateApplication

Il seguente codice di richiesta di esempio per l'CreateApplicationazione crea un servizio gestito per l'applicazione 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

Il seguente codice di richiesta di esempio per l'CreateApplicationSnapshotazione crea un'istantanea dello stato dell'applicazione:

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

DeleteApplication

Il seguente codice di richiesta di esempio per l'DeleteApplicationazione elimina un'applicazione Managed Service for Apache Flink:

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

DeleteApplicationCloudWatchLoggingOption

Il seguente codice di richiesta di esempio per l'DeleteApplicationCloudWatchLoggingOptionazione elimina un'opzione di CloudWatch registrazione Amazon da un'applicazione Managed Service for Apache Flink:

{
    "ApplicationName": "MyApplication",
    "CloudWatchLoggingOptionId": "3.1"
    "CurrentApplicationVersionId": 3
}

DeleteApplicationInputProcessingConfiguration

Il seguente codice di richiesta di esempio per l'DeleteApplicationInputProcessingConfigurationazione rimuove una configurazione di elaborazione dell'input da un'applicazione Managed Service for Apache Flink:

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

DeleteApplicationOutput

Il seguente codice di richiesta di esempio per l'DeleteApplicationOutputazione rimuove l'output di un'applicazione da un'applicazione Managed Service for Apache Flink:

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

DeleteApplicationReferenceDataSource

Il seguente codice di richiesta di esempio per l'DeleteApplicationReferenceDataSourceazione rimuove un'origine dati di riferimento dell'applicazione da un'applicazione Managed Service for Apache Flink:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 5,
   "ReferenceId": "5.1"
}

DeleteApplicationSnapshot

Il seguente codice di richiesta di esempio per l'DeleteApplicationSnapshotazione elimina un'istantanea dello stato dell'applicazione:

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

DeleteApplicationVpcConfiguration

Il seguente codice di richiesta di esempio per l'azione DeleteApplicationVpcConfiguration rimuove una configurazione VPC esistente da un'applicazione:

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

DescribeApplication

Il seguente codice di richiesta di esempio per l'DescribeApplicationazione restituisce i dettagli su un'applicazione Managed Service for Apache Flink:

{"ApplicationName": "MyApplication"}

DescribeApplicationSnapshot

Il seguente codice di richiesta di esempio per l'DescribeApplicationSnapshotazione restituisce dettagli su un'istantanea dello stato dell'applicazione:

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

DiscoverInputSchema

Il seguente esempio di codice di richiesta per l'DiscoverInputSchemaazione genera uno schema da una sorgente di 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"
}

Il seguente codice di richiesta di esempio per l'DiscoverInputSchemaazione genera uno schema da una fonte di riferimento:

{
   "S3Configuration": { 
      "BucketARN": "arn:aws:s3:::amzn-s3-demo-bucket",
      "FileKey": "TickerReference.csv"
   },
   "ServiceExecutionRole": "arn:aws:iam::123456789123:role/myrole"
}

ListApplications

Il seguente codice di richiesta di esempio per l'ListApplicationsazione restituisce un elenco di applicazioni Managed Service for Apache Flink presenti nell'account:

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

ListApplicationSnapshots

Il seguente codice di richiesta di esempio per l'ListApplicationSnapshotsazione restituisce un elenco di istantanee dello stato dell'applicazione:

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

StartApplication

Il seguente codice di richiesta di esempio per l'StartApplicationazione avvia un'applicazione Managed Service for Apache Flink e carica lo stato dell'applicazione dall'ultima istantanea (se presente):

{
    "ApplicationName": "MyApplication",
    "RunConfiguration": {
        "ApplicationRestoreConfiguration": { 
         "ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT"
         }
    }
}

StopApplication

Il seguente codice di richiesta di esempio per l'azione API_STopApplication interrompe un'applicazione Managed Service for Apache Flink:

{"ApplicationName": "MyApplication"}

UpdateApplication

Il seguente codice di richiesta di esempio per l'UpdateApplicationazione aggiorna un'applicazione Managed Service for Apache Flink per modificare la posizione del codice dell'applicazione:

{"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"
         }
      }
   }
}