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 di Managed Service per Apache Flink API

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

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

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

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

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

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 una fonte di dati di riferimento CSV dell'applicazione 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'AddApplicationVpcConfigurationazione aggiunge una VPC configurazione 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'DeleteApplicationVpcConfigurationazione rimuove una VPC configurazione 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'API_StopApplicationazione 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"
         }
      }
   }
}