Uso de um gatilho de DIS

Pré-requisitos

Antes de criar um gatilho, certifique-se de ter preparado o seguinte:

• Você criou uma função. Para mais detalhes, veja Criação de uma função a partir do zero.
• Você criou um fluxo DIS, por exemplo, dis-function.Para obter detalhes, consulte Criação de um fluxo de DIS.

Configuração de uma agência

Antes de criar um gatilho de DIS, defina uma agência para delegar FunctionGraph para acessar o DIS. Para obter detalhes sobre como criar uma agência, consulte Configuração das permissões de agência.

Como você não especificou uma agência ao criar a função HelloWorld, especifique uma primeiro.

1. Efetue log-in no Console do FunctionGraph. No painel de navegação, escolha Functions > Function List.
2. Clique na função a ser configurada para ir para a página de detalhes da função.
3. Escolha Configuration > Permissions e altere a agência para serverless-trust criada em Configuração das permissões de agência.
4. Clique em Save.

Criação de um gatilho de DIS

1. Efetue log-in no Console do FunctionGraph. No painel de navegação, escolha Functions > Function List.
2. Clique na função a ser configurada para ir para a página de detalhes da função.
3. Escolha Configuration > Trigger e clique em Create Trigger.
4. Defina os seguintes parâmetros:
   • Trigger Type: Selecione Data Ingestion Service (DIS).
   • Stream Name: Selecione um fluxo DIS, por exemplo, dis-function.
   • Max. Fetch Bytes: Volume máximo de dados que podem ser buscados em cada solicitação. Somente os registros menores que esse valor serão buscados. O valor varia de 1 KB a 4 MB.
   • Starting Position: Especifique uma posição no fluxo especificado a partir da qual iniciar a leitura de dados.
     • TRIM_HORIZON: Os dados são lidos a partir dos registos válidos mais antigos armazenados na partição.
     • latest: Os dados são lidos logo após o registro mais recente na partição. Essa configuração garante que você sempre leia os dados mais recentes.
   • Pull Period: Defina um período para extrair dados do fluxo.
   • Serial Data Processing: Se essa opção for selecionada, o FunctionGraph extrairá dados do fluxo somente depois que os dados anteriores forem processados. Se essa opção não for selecionada, o FunctionGraph extrairá dados do fluxo desde que o período de baixa termine.

5. Clique em OK.

Configuração de um evento de DIS para acionar a função

1. Efetue log-in no Console do FunctionGraph. No painel de navegação, escolha Functions > Function List.
2. Clique na função a ser configurada para ir para a página de detalhes da função.
3. Na página de detalhes da função, selecione uma versão.
4. Na página de guia Code, clique em Test. A caixa de diálogo Configure Test Event é exibida.
5. Defina os parâmetros descritos em Tabela 1 e clique em Tabela 1.

   Tabela 1 Informações sobre o evento de teste

   Parâmetro	Descrição
   Configure Test Event	Você pode optar por criar um evento de teste ou editar um existente. Use a opção padrão Create new test event.
   Event Template	Selecione dis-event-template.
   Event Name	O nome do evento pode conter de 1 a 25 caracteres e deve começar com uma letra e terminar com uma letra ou dígito. Apenas letras, dígitos, sublinhados (_), e hífens (-) são permitidos. Por exemplo, dis-123test.
   Event data	O sistema carrega automaticamente o modelo de evento DIS embutido, que é usado neste exemplo sem modificações. O código neste modelo é o seguinte:

   

   The event template is as follows:

   {
       "ShardID": "shardId-0000000000",
       "Message": {
           "next_partition_cursor": "eyJnZXRJdGVyYXRvclBhcmFtIjp7InN0cmVhbS1uYW1lIjoiZGlzLXN3dGVzdCIsInBhcnRpdGlvbi1pZCI6InNoYXJkSWQtMDAwMDAwMDAwMCIsImN1cnNvci10eXBlIjoiVFJJTV9IT1JJWk9OIiwic3RhcnRpbmctc2VxdWVuY2UtbnVtYmVyIjoiNCJ9LCJnZW5lcmF0ZVRpbWVzdGFtcCI6MTUwOTYwNjM5MjE5MX0",
           "records": [
               {
                   "partition_key": "shardId_0000000000",
                   "data": "d2VsY29tZQ==",
                   "sequence_number": "0"
               },
               {
                   "partition_key": "shardId_0000000000",
                   "data": "dXNpbmc=",
                   "sequence_number": "1"
               },
               {
                   "partition_key": "shardId_0000000000",
                   "data": "RnVuY3Rpb25TdGFnZQ==",
                   "sequence_number": "2"
               },
               {
                   "partition_key": "shardId_0000000000",
                   "data": "c2VydmljZQ==",
                   "sequence_number": "3"
               }
           ],
           "millis_behind_latest": ""
       },
       "Tag": "latest",
       "StreamName": "dis-swtest"
   }

6. Clique em Test. O resultado do teste de função é exibido.