Crie seu serviço gerenciado para o aplicativo Apache Flink Python - Managed Service for Apache Flink
Especifique seus arquivos de código

Anteriormente, o Amazon Managed Service for Apache Flink era conhecido como Amazon Kinesis Data Analytics for Apache Flink.

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Crie seu serviço gerenciado para o aplicativo Apache Flink Python

Especifique seus arquivos de código

Quando você tiver criado o pacote de código do seu aplicativo, você deve carregá-lo em um bucket do Amazon S3. Em seguida, você cria seu aplicativo usando o console ou a CreateApplicationação.

Ao criar seu aplicativo usando a CreateApplicationação, você especifica os arquivos de código e arquivamentos em seu arquivo zip usando um grupo especial de propriedades do aplicativo chamadokinesis.analytics.flink.run.options. Você pode definir os seguintes tipos de arquivos:

  • python: um arquivo de texto contendo um método principal do Python.

  • jarfile: um JAR arquivo Java contendo funções Java definidas pelo usuário.

  • pyFiles: um arquivo de recursos do Python contendo recursos a serem usados pelo aplicativo.

  • pyArchives: um arquivo zip contendo arquivos de recursos para o aplicativo.

Para obter mais informações sobre os tipos de arquivo de código do Apache Flink Python, consulte Interface de linha de comando na documentação do Apache Flink.

nota

O Managed Service for Apache Flink não suporta os tipos de arquivo pyModule, pyExecutable ou pyRequirements. Todo o código, requisitos e dependências devem estar em seu arquivo zip. Você não pode especificar dependências a serem instaladas usando pip.

O exemplo de trecho json a seguir demonstra como especificar a localização dos arquivos no arquivo zip do seu aplicativo:

"ApplicationConfiguration": {
    "EnvironmentProperties": {
      "PropertyGroups": [
        {
          "PropertyGroupId": "kinesis.analytics.flink.run.options",
          "PropertyMap": {
            "python": "MyApplication/main.py",
            "jarfile": "MyApplication/lib/myJarFile.jar",
            "pyFiles": "MyApplication/lib/myDependentFile.py",
            "pyArchives": "MyApplication/lib/myArchive.zip"
          }
        },