Este conteúdo foi traduzido por máquina para sua conveniência e a Huawei Cloud não pode garantir que o conteúdo foi traduzido com precisão. Para exibir o conteúdo original, use o link no canto superior direito para mudar para a página em inglês.

Central de ajuda> FunctionGraph> Guia de usuário> Criação de gatilhos> Uso de um gatilho de Kafka

Atualizado em 2022-11-16 GMT+08:00

Ver PDF

Uso de um gatilho de Kafka

Esta seção descreve como criar um gatilho de Kafka e configurar um evento de Kafka para acionar uma função.

Depois que um gatilho de Kafka é usado, o FunctionGraph pesquisa periodicamente novas mensagens em um tópico específico em uma instância do Kafka e passa as mensagens como parâmetros de entrada para chamar funções. Para obter detalhes sobre a origem de eventos do DMS for Kafka, consulte Fontes de eventos suportadas.

Pré-requisitos

Antes de criar um gatilho, certifique-se de ter preparado o seguinte:

Você criou uma função. Para mais detalhes, consulte Criação de uma função a partir do zero.
Você ativou o acesso VPC para a função. Para mais detalhes, consulte Configuração da rede.
Você criou uma instância de Kafka. Para obter detalhes, consulte Compra de uma instância.
Você criou um tópico sob uma instância de Kafka. Para obter detalhes, consulte Criação de um tópico.

Criação de um gatilho de Kafka

Efetue log-in no Console do FunctionGraph. No painel de navegação, escolha Functions > Function List.
Clique na função a ser configurada para ir para a página de detalhes da função.
Escolha Configuration > gatilho e clique em Create gatilho.

Figura 1 Criação de um gatilho
Configure os parâmetros a seguir:
- Trigger Type: selecione Distributed Message Service for Kafka (Kafka).
- Instance selecione uma instância premium de Kafka.
- Topic: Selecione um tópico da instância premium de Kafka.
- Batch Size: Defina o número de mensagens a serem recuperadas de um tópico a cada vez.
- Username: Informe o nome de usuário da instância se o SSL tiver sido ativado para ela.
- Password: Informe a senha da instância se o SSL tiver sido ativado para ela.
Clique em OK.

Depois que o acesso à VPC for ativado, você precisará configurar as permissões de sub-rede correspondentes para o grupo de segurança de Kafka. Para obter detalhes sobre como configurar o acesso à VPC, consulte Configuração da rede.

Configuração de um evento de Kafka para acionar a função

Efetue log-in no Console do FunctionGraph. No painel de navegação, escolha Functions > Function List.
Clique na função a ser configurada para ir para a página de detalhes da função.
Na página de detalhes da função, selecione uma versão.
Na página de guia Code, clique em Test. A caixa de diálogo Configure Test Event é exibida.

Defina os parâmetros descritos em Tabela 1 e clique em Save.

**Tabela 1** Informações sobre o evento de teste
Parâmetro	Descrição
Configure Test Event	Você pode optar por criar um evento de teste ou editar um existente. Use a opção padrão Create new test event.
Event Template	Selecione kafka-event-template.
Event Name	O nome do evento pode conter de 1 a 25 caracteres e deve começar com uma letra e terminar com uma letra ou dígito. Apenas letras, dígitos, sublinhados (_), e hífens (-) são permitidos. Por exemplo, kafka-123test.
Event data	O sistema carrega automaticamente o modelo de evento Kafka integrado, que é usado neste exemplo sem modificações.

O modelo de evento é o seguinte:

{
	"event_version": "v1.0",
	"event_time": 1576737962,
	"trigger_type": "KAFKA",
	"region": "xx-xxxx-1",
	"records": [{
		"messages": [
			"kafka message1",
			"kafka message2",
			"kafka message3",
			"kafka message4",
			"kafka message5"
		],
	"instance_id": "81335d56-b9fe-4679-ba95-7030949cc76b",
	"topic_id": "topic-test"
	}]
}