• Guias
• Send Event To Endpoint

Azion Send Event to Endpoint é uma integração serverless disponível no Marketplace da Azion. Essa integração permite transmitir dados de uma requisição para um endpoint HTTP, recolhendo os dados de requisição e os transmitindo para um endpoint definido pelo usuário por meio de uma API Javascript.

A integração também possibilita que você especifique que tipo de dados deseja recolher editando um arquivo JSON.

Após o envio dos dados coletados, a integração permite que a requisição prossiga através do Rules Engine.

Para usar a integração Send Event to Endpoint, siga estes passos:

1. Acesse o Azion Console > Marketplace.
2. Na homepage do Marketplace, selecione o card da integração.
3. Quando a página da integração abrir, clique no botão Get It Now, localizado no canto inferior da direita.

Aparecerá uma mensagem indicando que sua integração foi instalada com sucesso.

Para iniciar este processo, siga os passos:

1. Em Products menu, selecione Edge Firewall na seção SECURE.
2. Clique no botão Add Rule Set.
3. Dê um nome fácil de lembrar ao seu edge firewall.
4. Selecione os domínios que deseja proteger com a função.
5. Habilite o switch para Edge Functions.
6. Clique no botão Save

Pronto. Você instanciou o edge firewall para sua função.

Para instanciar a integração Send Event to Endpoint, enquanto ainda estiver na página do Edge Firewall, selecione a aba Functions e siga estas passos:

1. Clique no botão Add⁠ Function.
2. Dê um nome fácil de lembrar à sua instância.
3. No menu suspenso, selecione a função Send Event to Endpoint.

Depois de selecionar a integração, um formulário com o código-fonte da integração será carregado. O⁠ código-fonte da integração não pode ser modificado. No mesmo formulário, você tem outra aba: Args. Na aba Args, você passará os parâmetros para configurar sua integração.

O formulário JSON das Args para esta integração ficará assim:

{
  "metadata": ["remote_addr"],
  "headers": ["x-hello"],
  "body": ["message", "user.id"],
  "http_connection_args": {
  "endpoint": "http://example_api:3000/test",
  "headers": {
    "Authorization": "FakeAuth",
      "X-Provider": "Azion Cells"
  }
  }
}

Onde:

Esta integração retornará uma resposta com os dados transmitidos em um arquivo JSON com a seguinte aparência:

{
  "body": {
  "field_a": <data>,
  ...
  },
  "geoip_asn": <data>,
  "geoip_city": <data>,
  "geoip_city_continent_code": <data>,
  "geoip_city_country_code": <data>,
  "geoip_city_country_name": <data>,
  "geoip_continent_code": <data>,
  "geoip_country_code": <data>,
  "geoip_country_name": <data>,
  "geoip_region": <data>,
  "geoip_region_name": <data>,
  "headers": {
  "x-header-a": <data>,
  ...
  },
  "remote_addr": <data>,
  "remote_port": <data>,
  "remote_user": <data>,
  "request_id": <data>,
  "request_url": <data>,
  "server_protocol": <data>,
  "ssl_cipher": <data>,
  "ssl_protocol": <data>
}

Observe como os campos request_id, request_url e metadados serão entregues na raiz do arquivo JSON, enquanto os campos body e os cabeçalhos da requisição serão enviados nos objetos.

Você também pode usar um arquivo JSON “catch-all” para as Args, como este:

{
    "connection_args": {
        "endpoint": "http://example_api:3000/test",
    }
}

Para cada nova execução da função, um novo arquivo será gerado no bucket S3 fornecido. O arquivo será nomeado com base no ID da requisição que iniciou a função.

Exemplo: se o parâmetro connection_args.file_path estiver definido como /meus-dados/ e a função for executada em 9 de maio de 2023, com o ID da requisição abcd-1234, o arquivo resultante será salvo em /meus-dados/2023-05-09/abcd-1234.json. Se o parâmetro connection_args.use_date_prefix estiver definido como false, o arquivo resultante será salvo como /meus-dados/abcd-1234.json.

Se não forem fornecidos http_connection_args ou s3_connection_args nos argumentos JSON, a função não terá nenhum argumento de conexão válido para utilizar. A requisição será encerrada e uma mensagem de erro em formato JSON será enviada para indicar a causa do problema.

{
  "error": "A001",
  "detail": "The function instance is missing or has invalid required arguments."
}

Se a função não conseguir se conectar ao endpoint HTTP ou ao provedor S3, a requisição do usuário será ignorada. Independentemente disso, um registro de erro será criado, ao qual o cliente poderá ter acesso por meio do Data Stream.

Por exemplo, se uma chave de acesso inválida for usada, será exibido o seguinte aviso:

[Send event to endpoint] S3 connection error;
<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<Error>
  <Code>InvalidAccessKeyId</Code>
  <Message>The key 'DAKEY' is not valid</Message>
</Error>

Por fim, se você fornecer as opções de conexão corretas tanto para o endpoint HTTP quanto para o bucket S3, a função entregará os dados do evento para ambas as fontes simultaneamente.

Para concluir, você precisa configurar o Rules Engine para definir o comportamento e os critérios para executar a integração.

Ainda na página Edge Firewall, selecione a aba Rules Engine e siga estes passos:

1. Clique no botão New Rule.
2. Dê um nome fácil de lembrar à sua nova regra.
3. Selecione um criterio (criteria) para executar a integração. Por exemplo: if Hostname is equal xxxxxxxxxxxx.map.azionedge.net/classes.
4. Abaixo, selecione um comportamento para os criteria. Neste caso, será Run Function. Em seguida, selecione a função Send Event to Endpoint de acordo com o nome que você deu a ela na etapa instanciada.

Pronto. Agora, a integração Send Event to Endpoint está sendo executada para cada requisição feita ao domínio indicado.

Contribuidores