Compartilhar via


Adicionar origem HTTP a um fluxo de eventos (versão prévia)

Este artigo mostra como adicionar uma fonte HTTP a um fluxo de eventos.

O conector HTTP fornece uma maneira configurável e sem código de transmitir dados de qualquer API REST diretamente para Eventstream para processamento em tempo real. Ele permite que você efetue pull contínuo de dados de plataformas SaaS e feeds de dados públicos e analise automaticamente as respostas JSON em eventos estruturados. Ele também oferece feeds públicos de exemplo para ajudá-lo a começar rapidamente, basta selecionar uma API de exemplo, inserir sua chave de API e permitir que o Eventstream preenchi os cabeçalhos e parâmetros necessários.

Pré-requisitos

  • Um workspace com capacidade do Fabric ou modo de avaliação de licença.
  • Acesso ao workspace com Colaborador ou papéis de workspace superiores.
  • Se você não tiver um fluxo de eventos, siga o guia para criar um fluxo de eventos.

Adicionar HTTP como fonte

Se você ainda não adicionou nenhuma fonte ao fluxo de eventos, selecione o bloco Usar o código-fonte externo .

Captura de tela que mostra a seleção do bloco para usar uma origem externa.

Se você estiver adicionando a origem a um fluxo de eventos já publicado, alterne para modo de edição. Na faixa de opções, selecione Adicionar origem>Fontes externas.

Captura de tela que mostra seleções para adicionar fontes externas.

Pesquise por http e selecione Conectar para adicionar o conector HTTP ao fluxo de eventos.

Captura de tela que mostra a seleção de HTTP como o tipo de origem no assistente Selecionar uma fonte de dados.

Configurar e conectar-se ao HTTP

Você pode selecionar uma das APIs públicas de exemplo para começar rapidamente com cabeçalhos e parâmetros predefinidos ou selecionar Sair para configurar seu próprio conector HTTP personalizado.

Usar APIs públicas de exemplo

  1. Selecione um exemplo de API pública para configurar rapidamente o conector HTTP: captura de tela que mostra a página de API de exemplo.

    • Binance. Obter o preço mais recente do Bitcoin
    • CoinGecko. Obter o preço atual do Bitcoin em USD
    • Transporte para Londres. Obter previsões de chegada ao vivo para uma estação de Londres
    • Vantagem Alfa. Obter o preço das ações da MSFT em tempo real
    • OpenWeather. Obter a previsão do tempo para um local
    • NewsAPI. Obter as últimas manchetes de negócios nos EUA
  2. Para APIs que exigem uma chave de API, use o link fornecido para aplicar à chave de API e insira-a na caixa de entrada. O conector cria automaticamente a conexão de nuvem do Fabric e preenche os cabeçalhos e parâmetros HTTP necessários.

    Importante

    A API de exemplo binance não requer uma chave de API, mas você é responsável por cumprir seus Termos de Uso.

  3. Se você escolher Usar conexão existente, selecione Aplicar exemplo para pré-armazenar os cabeçalhos e parâmetros necessários para a API de exemplo sem inserir uma chave de API.

  4. Como alternativa, selecione Sair para fechar a janela e configurar sua própria fonte HTTP do zero.

Configurar sua própria fonte HTTP

Siga as etapas para configurar sua própria fonte HTTP sem uma API de exemplo.

  1. Crie uma nova conexão. Selecione Nova conexão e insira as propriedades necessárias para sua fonte HTTP:

    Captura de tela que mostra onde selecionar a nova página de conexão.

    • URL base: a URL base do ponto final HTTP.
    • Uri de Audiência de Token (opcional): o recurso para o qual o token se destina.
    • Nome da conexão: insira um nome para a conexão.
    • Tipo de autenticação: Atualmente, o conector HTTP só dá suporte à autenticação Anonymous, Basic, e API Key.

    Captura de tela que mostra a nova página de conexão.

  2. Método de solicitação: Selecionar GET ou POST.

  3. Cabeçalhos e parâmetros: se você selecionou a autenticação de chave de API ao criar a conexão de nuvem, use o parâmetro dinâmico ${apiKey} em seus cabeçalhos ou parâmetros para referenciar a Chave de API.

    Por exemplo, para se conectar ao CoinGecko, use o cabeçalho: x_cg_demo_api_key = ${apiKey}.

    Importante

    NÃO insira sua chave de API ou outras credenciais nos cabeçalhos ou parâmetros.

  4. Intervalo de solicitação (s): especifica o tempo em segundos para aguardar entre solicitações consecutivas; o intervalo válido é [1, 3600].

  5. Tentativas máximas: o número máximo de vezes que o conector tenta novamente uma solicitação quando ocorre um erro; o intervalo válido é [10, 100].

  6. Retração de tentativa (s): o tempo de espera em segundos após um erro antes que o conector tente novamente; o intervalo válido é [1, 3600].

  7. Código de status de tentativa: os códigos de erro HTTP retornados que fazem com que o conector repita a solicitação. Insira uma lista separada por vírgulas de códigos ou intervalo de códigos. Os intervalos são especificados com um código de início e um código de término opcional. Por exemplo:

    • 400- inclui todos os códigos maiores ou iguais a 400.
    • 400-500 inclui códigos de 400 até 500, incluindo o código 500.
    • 404,408,500- solicita que o conector tente novamente em 404 NOT FOUND, 408 REQUEST TIMEOUT e todos os códigos de erro 5xx.

    Alguns códigos de status são sempre repetidos, como não autorizados, tempos limite e muitas solicitações.

    Captura de tela que mostra as configurações definidas.

  8. Examine o resumo de configuração da origem HTTP e selecione Adicionar.

    Captura de tela que mostra a página de configuração de revisão.

Você pode ver a origem HTTP adicionada ao fluxo de eventos no modo Editar.

Uma captura de tela da fonte HTTP adicionada no modo Editar com o botão Publicar realçado.

Selecione Publicar para publicar as alterações e iniciar o streaming de dados da fonte HTTP para o fluxo de eventos.

Uma captura de tela da fonte HTTP adicionada no modo de exibição Live com o botão Publicar realçado.

Limitation

  • Atualmente, o conector HTTP dá suporte apenas a respostas da API JSON .
  • Não há suporte para autenticação OAuth.
  • A origem HTTP não dá suporte a recursos de CI/CD, incluindo Integração com Git e Pipeline de Implantação. Exportar ou importar um item Eventstream que inclua essa origem por meio do Git pode resultar em erros.

Outros conectores: