Produtor - com escopo (descontinuado)

  • Versão de lançamento: Xanadu
  • Atualizado 1 de ago. de 2024
  • 1 min. de leitura
  • A API do produtor fornece métodos que permitem enviar dados de uma instância ServiceNow para um tópico do Kafka.

    Nota:
    Esta API está obsoleta e foi substituída pela API ProdutorV2 - Com escopo.

    Esta API requer o plug-in ServiceNow Integration Hub Action Step - Kafka Producer (com.glide.hub.action_step.kafka) e é fornecida no namespace sn_ih_kafka.

    Produtor - send(tópico de cadeia de caracteres, chave de cadeia de caracteres, mensagem de cadeia de caracteres, booliano isSync)

    Envia a mensagem especificada para o tópico Kafka especificado.

    Tabela 1. Parâmetros
    Nome Tipo Descrição
    tópico Cadeia de caracteres

    Nome do tópico no qual a mensagem será publicada. Um tópico armazena mensagens do mesmo tipo. Por exemplo, um tópico chamado Pagamentos pode armazenar mensagens sobre pagamentos recentes.

    Ao inserir o nome do tópico, inclua tudo o que vem após o prefixo do nome da instância. Por exemplo, se o nome completo do tópico for snc.<instancename> .sn_streamconnect.<topicname> , insira sn_streamconnect. no campo de tópico.

    chave Cadeia de caracteres Nome da chave para uma partição específica. Os tópicos podem ser particionados. Mensagens com a mesma chave são armazenadas na mesma partição. Por exemplo, as mensagens de pagamento com uma chave de junho seriam todas armazenadas na mesma partição do tópico Pagamentos.
    mensagem Cadeia de caracteres Texto da mensagem.
    estáSincronizado Booliano Sinalizador que indica se o fluxo deve aguardar a conclusão da etapa antes de continuar.
    Valores válidos:
    • verdadeiro: aguarde a conclusão da etapa antes de continuar o fluxo associado.
    • falso: não espere a etapa ser concluída antes de continuar o fluxo associado.
    Tabela 2. Retorna
    Tipo Descrição
    Nenhum(a)

    Este exemplo mostra como enviar informações de incidentes alterados para o tópico change_incidents do Kafka.

    var message = {
      'number': current.number.toString(),
      'short_description': current.short_description.toString(),
      'caller_id': current.caller_id.getDisplayValue(),
      'priority': current.priority.toString(),
      'state': current.state.toString()
    };
    
    var producer = new sn_ih_kafka.Producer();
    producer.send('changed_incidents', current.number.toString(), JSON.stringify(message), false);