1. Documentação
2. Produtos
3. Data Streaming

Data Streaming

Edite no GitHub

Data Streaming é um produto de Edge Analytics que permite a você alimentar suas plataformas de SIEM, big data e stream processing com dados de acesso ao seu conteúdo e aplicações em tempo real, adicionando ainda mais inteligência ao seu negócio.

Essa integração permite que você analise o comportamento de seus usuários e da performance dos seus conteúdos, aplicações e troubleshooting, de forma simples e ágil.

Além disso, o Data Streaming segue as boas práticas de tráfego de informações, utilizando a codificação ASCII para evitar problemas de parser, ou seja, na interpretação dos dados.

1. Acessar o Data Streaming
2. Selecionar o Data Source
3. Utilizar um Template
4. Associar Domains
5. Definir o Endpoint
6. Personalizar o Payload
7. Ativar suas Configurações

1. Acessar o Data Streaming

Acesse o Real-Time Manager. Clique em Data Streaming no menu de Edge Analytics ou em Products, no menu superior esquerdo. Configure seu Data Streaming conforme as possibilidades a seguir.

Os campos marcados com asterisco são obrigatórios.

2. Selecionar o Data Source

A primeira etapa é a escolha do Data Source, que representa a aplicação na Azion que gerou os registros de eventos. Para isso, você deve selecionar de onde seus dados serão coletados, com as seguintes opções:

Edge Applications

Apresenta os dados de requisições realizadas às suas edge applications na Azion.

Edge Functions

Caso tenha contratado Edge Functions, utilize as seguintes variáveis disponíveis para o data source definido.

WAF

Caso tenha contratado o produto Web Application Firewall, o data source WAF Events apresentará as requisições analisadas pelo WAF para permitir que você mapeie o score atribuído à requisição, às regras de WAF que deram match, ao motivo do bloqueio e muito mais.

3. Utilizar um Template

O template representa uma seleção de variáveis que devem ser coletadas e um formato para transferência. Você pode selecionar templates criados e mantidos pela Azion ou customizar sua própria seleção.

• Custom Template: Selecione a opção Custom Template para criar seu próprio Data Set personalizado, no formato JSON, e selecionar as variáveis mais adequadas às suas necessidades.

Consulte a lista de Data Sources, onde você encontra uma descrição de todas as variáveis disponíveis. Experimente!

Por padrão, o Data Streaming enviará seus eventos quando o bloco atingir 2.000 registros ou a cada 60 segundos, o que ocorrer primeiro. Mas no caso de você escolher o endpoint AWS Kinesis Firehose, o Data Streaming enviará seus eventos quando o bloco atingir 500 registros ou a cada 60 segundos.

Seus registros serão separados pelo caractere \n e enviados no payload para seu endpoint.

4. Associar Domains

Você pode associar ao Data Streaming um ou mais de seus domínios cadastrados na Azion.

Ao associar um domínio ao Data Streaming, os eventos associados a esse domínio serão coletados e enviados para seu endpoint.

Você também pode definir o percentual de dados que deseja receber do seu Data Streaming através da opção Sampling. Além de filtrar por amostragem, ainda pode reduzir custos para recebimento e análise dos dados.

• Sampling

1. Selecione a opção All Domains para habilitar a opção Sampling.
2. Insira o número relativo ao percentual de dados que deseja receber. Este percentual retornará o total de dados relativo a todos os seus domínios.

Quando a opção Sampling estiver ativada, é permitido incluir apenas um Data Streaming. Caso esse Data Streaming seja desativado, a opção Add Data Streaming será habilitada novamente.

5. Definir o Endpoint

Endpoint é o destino para onde você deseja enviar os dados coletados pela Azion.

O tipo de endpoint representa o método que seu endpoint está configurado para receber os dados do Data Streaming. Conheça a seguir.

Apache Kafka

A utilização deste tipo de endpoint, faz com que o serviço de Data Streaming envie os dados para um endpoint Kafka em sua infraestrutura.

• Bootstrap Servers: refere-se aos servidores no cluster Kafka, no formato “host1:port1, host2:port2, …”.

  O usuário pode adicionar uma lista de servidores que irão receber os dados. Para isso cada host:door deve ser separado por “,”.

  Esse campo pode ser preenchido conforme este exemplo:

  myownhost.com:2021,imaginaryhost.com:4525,anotherhost:4030

  Essa lista não precisa conter todos os servidores de seu cluster, apenas alguns servidores que serão utilizados para a conexão inicial.

  Recomendamos que você utilize mais de um server para aumentar a redundância e disponibilidade.

• Kafka Topic: você precisa definir um Topic onde deseja que o Data Streaming publique as mensagens em seu cluster.

  O usuário adiciona nesse campo o nome do tópico do Kafka onde serão postadas as mensagens. Independentemente de quantos endereços ele tenha cadastrado no campo Bootstrap Servers, é possível cadastrar apenas um tópico de destino.

  Por exemplo: azure.analytics.fct.pageviews.0

AWS Kinesis Data Firehose

Ao usar esse tipo de endpoint, o serviço de Data Streaming envia os dados diretamente para o serviço AWS Kinesis Data Firehose.

Quando você usar o AWS Kinesis Data Firehose, seus eventos serão agrupados em blocos de até 500 registros, em vez do padrão de 2.000, ou a cada 60 segundos, o que ocorrer primeiro.

• Stream Name: refere-se ao nome do stream que o usuário definiu ao criar o Kinesis Data Firehose. Por exemplo: MyKDFConnector

• Region: refere-se à região para a qual vamos enviar os dados.

  Por exemplo: us-east-1.

• Access Key: refere-se à chave pública para acessar o Data Firehose, que é fornecida pela AWS.

  Por exemplo:* ORIA5ZEH9MW4NL5OITY4

• Secret Key: refere-se à chave secreta para acessar o Data Firehose, que é fornecida pela AWS.

  Por exemplo: +PLjkUWJyOLth3anuWXcLLVrMLeiiiThIokaPEiw

Elasticsearch

A utilização deste tipo de endpoint faz com que o serviço de Data Streaming envie os dados para um endpoint Elasticsearch em sua infraestrutura.

• Elasticsearch URL: (obrigatório) refere-se ao endereço da URL mais o index do ElasticSearch que irá receber os dados coletados do Data Streaming.

  O usuário deve cadastrar aqui a URL de destino dos dados, seguido pelo index. Por exemplo: https://elasticsearch-domain.com/myindex

• API Key: (obrigatório) refere-se à chave em base 64 fornecida pelo Elasticsearch e que será usada para a validação junto ao mesmo.

  Quando gerada, a chave ficará como no exemplo:

  VuaCfGcBCdbkQm-e5aOx:ui2lp2axTNmsyakw9tvNnw

Google BigQuery

A utilização deste tipo de endpoint faz com que o serviço de Data Streaming envie os dados para um endpoint Google BigQuery em sua infraestrutura.

• Project ID: refere-se ao ID do seu projeto no Google Cloud. Esse ID é único e pode ter sido gerado pelo Google ou personalizado pelo cliente.

  Exemplo: mycustomGBQproject01

• Dataset ID: refere-se ao ID do seu dataset no Google BigQuery, ou seja, é o nome que o usuário atribui ao seu conjunto de dados. Ele é único por projeto e diferencia maiúsculas de minúsculas.

  Exemplo: myGBQdataset

• Table ID: refere-se ao ID da sua tabela no Google BigQuery, ou seja, é o nome que o usuário define para a tabela. Assim como o nome do dataset precisa ser único por projeto, o nome da tabela também precisa ser único por dataset.

  Exemplo: mypagaviewtable01

• Service Account Key: refere-se ao arquivo JSON fornecido pelo Google Cloud, que possui a chave a ser usada para autenticação junto aos serviços do Google. Ele possui o seguinte formato:

{
  "type": "service_account",
  "project_id": "mycustomGBQproject01",
  "private_key_id": "key-id",
  "private_key": "-----BEGIN PRIVATE KEY-----\nprivate-key\n-----END PRIVATE KEY-----\n",
  "client_email": "service-account-email",
  "client_id": "client-id",
  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
  "token_uri": "https://accounts.google.com/o/oauth2/token",
  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
  "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/service-account-email"
}

Simple Storage Service (S3)

A utilização deste tipo de endpoint faz com que o serviço de Data Streaming envie os dados diretamente para qualquer storage que trabalhe com o protocolo S3, como por exemplo o Amazon S3, Cloud Storage, entre outros.

• Host URL: refere-se à URL do seu Host S3.

  Você pode conectar com qualquer provedor que trabalhe com o protocolo S3.

  Por exemplo: http://myownhost.s3.us-east-1.myprovider.com

• Bucket Name: refere-se ao nome do Bucket que o objeto será enviado.

  É importante que o Bucket já esteja criado para que o Data Streaming possa enviar os objetos.

  Você define o nome do bucket. Por exemplo: mys3bucket

• Region: refere-se à região na qual o Bucket está hospedado.

  Por exemplo: us-east-1.

• Access Key: refere-se à chave pública para acesso ao Bucket fornecida pelo seu provedor.

  Por exemplo: ORIA5ZEH9MW4NL5OITY4

• Secret Key: refere-se à chave secreta para acesso ao Bucket fornecida pelo seu provedor.

  Por exemplo: +PLjkUWJyOLth3anuWXcLLVrMLeiiiThIokaPEiw

• Object Key Prefix: refere-se a um prefixo que você pode adicionar aos arquivos que serão enviados.

  Os nomes dos objetos são compostos de Prefixo + Timestamp + UUID.

  Por exemplo, se você usar waf_logs como prefixo, um dos objetos enviados será salvo desta forma: waf_logs_1622575860091_37d66e78-c308-4006-9d4d-1c013ed89276

• Content Type: é o formato em que o objeto será criado no Bucket.

  Conta com as opções plain/text e application/gzip.

Com base nesses exemplos, ao configurar a seção Destination, você obtém o seguinte:

Splunk

Ao usar esse tipo de endpoint, o serviço do Data Streaming envia dados para um endpoint Splunk em sua infraestrutura.

• Splunk URL: (obrigatório) refere-se ao URL que receberá os dados coletados do Data Streaming. Se você tiver um índice alternativo para indicar, pode colocar no final do URL, por exemplo: https://inputs.splunkcloud.com:8080/services/collector?index=myindex
• API Key: (obrigatório) refere-se ao token do HTTP Event Collector, fornecido pela instalação do Splunk. Exemplo de token: crfe25d2-23j8-48gf-a9ks-6b75w3ska674

Standard HTTP/HTTPS POST

A utilização deste tipo de endpoint faz com que o serviço de Data Streaming envie os dados no payload de um POST HTTP para o processamento em sua plataforma.

• Endpoint URL: refere-se à URL configurada em sua plataforma para receber os dados do Data Streaming.

  Utilize o formato scheme://domain/path. Por exemplo: https://app.domain.com/

• Custom Headers: você pode informar um ou mais cabeçalhos customizados para a sua requisição HTTP/HTTPS. Para a configuração dos headers, é necessário informar o Nome e o Valor para cada cabeçalho.

  Por exemplo, se você deseja informar a autorização e a chave secreta, seus cabeçalhos personalizados ficarão assim:

  

6. Personalizar o Payload

Você também pode personalizar o Payload enviado pelo conector conforme as opções a seguir.

• Log Line Separator: (opcional) define o tipo de informação que vai ser utilizada ao final de cada linha de log.
• Payload Format: (opcional) define qual informação vai estar no inicio e no final do dataset.

Por exemplo, se o Log Line Separator receber “,” e o Payload Format receber “[&dataset]”, o usuário receberá o seguinte código de saída:

[{ "request_method": "GET", "host": "statis.exampledomain.com.br", "status": "200" },{ "request_method": "GET", "host": "statis.exampledomain.com.br", "status": "200" }]

Esta funcionalidade está dispoível apenas para o endpoint HTTP POST.

7. Ativar suas Configurações

Na parte inferior da tela, você encontra as seguintes opções:

• Active: ligue o botão Active para habilitar suas configurações no sistema.
• Cancel: com esta opção, você retorna à página inicial do Data Streaming, também descarta qualquer edição.
• Save: concluídas as suas seleções, salve suas configurações clicando no botão Save.

Não encontrou o que procurava? Abra um ticket.