Use o gatilho de mensagem do Kafka e o consumidor de script para consumir mensagens

Recupere mensagens do Hermes com o gatilho de mensagem do Kafka em Workflow Studio e o consumidor de script.

Antes de Iniciar

• Função necessária: integration_hub_admin
• Esta página faz parte de Stream Connect guia de início rápido.
• Este documento mostra como consumir mensagens por meio de sua conexão com o Hermes. Para configurar e testar sua conexão, consulte Set up a secure connection to the Hermes Messaging Service e Como testar a conexão com o Hermes por meio do gateway ADCv2.
• A primeira parte desta página mostra como usar o gatilho de mensagem do Kafka em Workflow Studio para consumir mensagens. Para obter mais informações sobre o gatilho, consulte Create a flow with a Kafka Message trigger. Para obter mais informações sobre Workflow Studio e como configurar fluxos, consulte .
• A segunda parte desta página mostra como usar o consumidor de script para consumir mensagens. Para obter mais informações, consulte Configurar um consumidor de script.

Procedimento

1. Crie um tópico para consumir mensagens.
   1. Use o seguinte comando para criar um tópico no Hermes.

      bin/kafka-topics.sh --create --command-config config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002, <instance name>.service-now.com:4003 --topic snc.<instance name>.topic1

      Certifique-se de substituir<instance name> com o nome da sua instância.
   2. Para exibir o tópico, faça login na instância e navegue até Todos > IntegrationHub > Conexão de fluxo > Tópicos.
      Nota:

      A criação de um tópico leva aproximadamente 10 minutos.
2. Crie um gatilho de fluxo para consumir mensagens do tópico.
   1. Navegar até Todos > Automação de Processo > Flow Designer.
   2. Selecionar Criar novo > Fluxo.
   3. No formulário Propriedades de fluxo, insira um nome para o fluxo e, em seguida, insira Enviar.
      Este exemplo usa o nome Topic1 Consumer.
   4. Na seção de gatilho, selecione Adicionar um gatilhoe, em seguida, selecione Mensagem do Kafka como o tipo de gatilho.

      

   5. Selecione o tópico Topic1.

      

      Você pode usar o ícone de lupa para ver a lista de tópicos disponíveis.

   6. Na seção Ações do fluxo, navegue até Adicionar uma Ação, Lógica de Fluxo ou Subfluxo > Lógica de fluxo > For Each.
   7. Arraste a cápsula de dados de Mensagens para o campo Itens e selecione Concluído.
   8. Na seção Ações do fluxo, navegue até Adicionar uma Ação, Lógica de Fluxo ou Subfluxo > Ação > ServiceNow Core > Log.
   9. Arraste a cápsula Dados de carga para o campo Mensagem e selecione Concluído.

      

   10. Salve o gatilho de fluxo.
   11. Acesse a tabela Configurações [sys_flow_execution_setting] para habilitar a emissão de relatórios para este fluxo.
   12. Crie uma nova entrada e habilite a emissão de relatórios para o fluxo criado acima.

       

   13. Navegue de volta para o fluxo e selecione Ativar.
   14. Para exibir sua assinatura de tópico, navegue até Todos > Hub de integração > Conexão de fluxo > Assinaturas.

       

3. Publique mensagens no tópico usando a ferramenta de linha de comando Kafka.
   1. Execute o seguinte comando para publicar mensagens no tópico.

      bin/kafka-console-producer.sh --topic snc.<instance name>.topic1  --producer.config  config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002,<instance name>.service-now.com:4003

      Certifique-se de substituir<instance name> com o nome da sua instância.

      Este comando solicita mensagens. Adicione algumas mensagens de exemplo. Este exemplo usa as seguintes mensagens.

      • Mensagem de teste 1
      • Mensagem de teste 2
      • Mensagem de teste 3

      Você deve receber as mensagens em cerca de um minuto.
   2. Navegue de volta para o fluxo e selecione Execuções.

      

   3. Abra a execução do fluxo.

      

   4. Para exibir as estatísticas desta assinatura, navegue até Todos > Hub de integração > Conexão de fluxo > Assinaturas, abra a assinatura e vá para a exibição de estatísticas.

      

4. Crie um consumidor de script para consumir mensagens do tópico.
   1. Navegar até IntegrationHub > Consumidores > Consumidores de script.
   2. Selecione Novo.
   3. No campo Nome, insira um nome para o consumidor de script.
      Este exemplo usa o consumidor Topic1.
   4. Defina o script para registrar a mensagem adicionando a seguinte lógica na caixa de script.

      for (var i = 0; i < messages.length; i++) {
            gs.info('Received message ' + JSON.stringify(messages[i].message));
       }
      

      

   5. Salve o formulário.
   6. Na seção Links relacionados, selecione Novo para adicionar um fluxo do Kafka para consumir as mensagens.
   7. No formulário Fluxo do Kafka, defina os seguintes valores de campo.
      • Nomear fluxo do Topic1.
      • Tópico para o tópico criado anteriormente, topic1.
      • Máximo de simultaneidade para 1.
      • Comece a consumirtodas as mensagens armazenadas no tópico. Esta opção permite que você leia as mensagens já publicadas neste tópico.
      • Manipulação de mensagens para otimizar automaticamente o.

      

   8. Selecione o link Ativar em Links relacionados.
      Você deve conseguir ver a assinatura ativada.
   9. Para exibir as mensagens, navegue até Todos > Logs do sistema > Log do sistema e filtrar mensagens que começam com Mensagem recebida.

      

   10. Você deve ver todas as mensagens após 1 minuto.

O que Fazer Depois

Use o ETL e os consumidores do mapa de transformação para importar dados.