Ejemplo de código de API de Managed Service para Apache Flink

Este tema contiene ejemplos de bloques de solicitud de acciones de Managed Service para Apache Flink.

Para usar JSON como entrada para una acción con la AWS Command Line Interface (AWS CLI), guarde la solicitud en un archivo JSON. A continuación, pase el nombre del archivo a la acción mediante el parámetro --cli-input-json.

En el siguiente ejemplo se muestra cómo utilizar un archivo JSON con una acción.


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

Para obtener más información sobre cómo usar JSON con la AWS CLI, consulte Generate CLI Skeleton and CLI Input JSON Parameters en la Guía del usuario de AWS Command Line Interface.

AddApplicationCloudWatchLoggingOption

El siguiente código de solicitud de ejemplo para la acción AddApplicationCloudWatchLoggingOption añade una opción de registro de Amazon CloudWatch a una aplicación de Managed Service para 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

El siguiente código de solicitud de ejemplo para la acción AddApplicationInput añade una entrada de aplicación a una aplicación de Managed Service para 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

El siguiente código de solicitud de ejemplo para la acción AddApplicationInputProcessingConfiguration añade una configuración de procesamiento de entradas de aplicación a una aplicación de Managed Service para Apache Flink:


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

AddApplicationOutput

El siguiente código de solicitud de ejemplo para la acción AddApplicationOutput añade un flujo de datos de Kinesis como salida de la aplicación a una aplicación de Managed Service para 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

El siguiente código de solicitud de ejemplo para la acción AddApplicationReferenceDataSource añade el origen de datos de referencia de la aplicación CSV a una aplicación de Managed Service para 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

El siguiente código de solicitud de ejemplo para la acción AddApplicationVpcConfiguration añade una configuración de VPC a una aplicación existente:


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

CreateApplication

El siguiente código de solicitud de ejemplo para la acción CreateApplication crea una aplicación de Managed Service para 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

El siguiente código de solicitud de ejemplo para la acción CreateApplicationSnapshot crea una instantánea del estado de la aplicación:


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

DeleteApplication

El siguiente código de solicitud de ejemplo para la acción DeleteApplication elimina una aplicación de Managed Service para Apache Flink:


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

DeleteApplicationCloudWatchLoggingOption

El siguiente código de solicitud de ejemplo para la acción DeleteApplicationCloudWatchLoggingOption elimina una opción de registro de Amazon CloudWatch de una aplicación de Managed Service para Apache Flink:


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

DeleteApplicationInputProcessingConfiguration

El siguiente código de solicitud de ejemplo para la acción DeleteApplicationInputProcessingConfiguration elimina una configuración de procesamiento de entradas de una aplicación de Managed Service para Apache Flink:


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

DeleteApplicationOutput

El siguiente código de solicitud de ejemplo para la acción DeleteApplicationOutput elimina una salida de la aplicación de una aplicación de Managed Service para Apache Flink:


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

DeleteApplicationReferenceDataSource

El siguiente código de solicitud de ejemplo para la acción DeleteApplicationReferenceDataSource elimina el origen de datos de referencia de la aplicación de una aplicación de Managed Service para Apache Flink:


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

DeleteApplicationSnapshot

El siguiente código de solicitud de ejemplo para la acción DeleteApplicationSnapshot elimina una instantánea del estado de la aplicación:


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

DeleteApplicationVpcConfiguration

El siguiente código de solicitud de ejemplo para la acción DeleteApplicationVpcConfiguration elimina una configuración de VPC existente de una aplicación:


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

DescribeApplication

El siguiente código de solicitud de ejemplo para la acción DescribeApplication proporciona detalles sobre una aplicación de Managed Service para Apache Flink:


{"ApplicationName": "MyApplication"}

DescribeApplicationSnapshot

El siguiente código de solicitud de ejemplo para la acción DescribeApplicationSnapshot proporciona detalles sobre una instantánea de del estado de la aplicación:


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

DiscoverInputSchema

El siguiente código de solicitud de ejemplo para la acción DiscoverInputSchema genera un esquema a partir de un origen 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"
}

El siguiente código de solicitud de ejemplo para la acción DiscoverInputSchema genera un esquema a partir de una fuente de referencia:


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

ListApplications

El siguiente código de solicitud de ejemplo para la acción ListApplications proporciona una lista de las aplicaciones de Managed Service para Apache Flink de su cuenta:


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

ListApplicationSnapshots

El siguiente código de solicitud de ejemplo para la acción ListApplicationSnapshots proporciona una lista de instantáneas del estado de la aplicación:


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

StartApplication

El siguiente código de solicitud de ejemplo para la acción StartApplication inicia una aplicación de Managed Service para Apache Flink y carga el estado de la aplicación a partir de la última instantánea (de haberla):


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

StopApplication

El siguiente código de solicitud de ejemplo para la acción API_StopApplication detiene una aplicación de Managed Service para Apache Flink:


{"ApplicationName": "MyApplication"}

UpdateApplication

El siguiente código de solicitud de ejemplo para la acción UpdateApplication actualiza una aplicación de Managed Service para Apache Flink para cambiar la ubicación del código de la aplicación:


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

Aviso JavaScript está desactivado o no está disponible en su navegador.

Para utilizar la documentación de AWS, debe estar habilitado JavaScript. Para obtener más información, consulte las páginas de ayuda de su navegador.

Convenciones del documento

Historial de revisión

referencia de la API