Uso de un activador Kafka
Esta sección describe cómo crear un activador de Kafka y configurar un evento de Kafka para activar una función.
Después de usar un activador de Kafka, el FunctionGraph sondea periódicamente nuevos mensajes en un tema específico en una instancia de Kafka y pasa los mensajes como parámetros de entrada para invocar funciones. Para obtener más información sobre el origen de eventos del DMS for Kafka, consulte Orígenes de eventos compatibles.
Prerrequisitos:
Antes de crear un activador, asegúrese de haber preparado lo siguiente:
- Ha creado una función en FunctionGraph. Para más detalles, consulte Creación de una función desde cero.
- Ha habilitado el acceso de VPC para la función. Para más detalles, consulte Configuración de VPC.
- Ha creado una instancia de Kafka. Para obtener más información, consulte Compra de una instancia.
- Ha creado un tema bajo una instancia de Kafka. Para obtener más información, consulte Creación de un tema.
Creación de un activador Kafka
- Inicie sesión en la consola de FunctionGraph. En el panel de navegación, seleccione Functions > Function List.
- Haga clic en la función que se va a configurar para ir a la página de detalles de la función.
- Seleccione Configuration > Trigger y haga clic en Create Trigger.
Figura 1 Creación de un activador
- Establezca los siguientes parámetros:
- Trigger Type: Seleccione Distributed Message Service for Kafka (Kafka).
- Instance: Seleccione una instancia premium de Kafka.
- Topic: Seleccione un tema de la instancia premium de Kafka.
- Batch Size: Establezca el número de mensajes que se recuperarán de un tema cada vez.
- Username: Introduzca el nombre de usuario de la instancia si SSL ha sido habilitado para ella.
- Password: Introduzca la contraseña de la instancia si SSL ha sido habilitado para ella.
- Haga clic en OK.
Después de habilitar el acceso a la VPC, debe configurar los permisos de subred correspondientes para el grupo de seguridad de Kafka. Para obtener más información sobre cómo habilitar el acceso de VPC, consulte Configuración de VPC.
Configuración de un evento Kafka para activar la función
- Inicie sesión en la consola de FunctionGraph. En el panel de navegación, seleccione Functions > Function List.
- Haga clic en la función que se va a configurar para ir a la página de detalles de la función.
- En la página de detalles de la función, seleccione una versión.
- En la página de la ficha Code, haga clic en Test. Aparece el cuadro de diálogo Configure Test Event.
- Defina los parámetros descritos en Tabla 1 y haga clic en Save.
Tabla 1 Información del evento de prueba Parámetro
Descripción
Configure Test Event
Puede elegir crear un evento de prueba o editar uno existente.
Utilice la opción predeterminada Create new test event.
Event Template
Seleccione kafka-event-template.
Event Name
El nombre del evento puede contener de 1 a 25 caracteres y debe comenzar con una letra y terminar con una letra o un dígito. Solo se permiten letras, dígitos, guiones bajos (_) y guiones (-). Por ejemplo, kafka-123test.
Event data
El sistema carga automáticamente la plantilla de eventos Kafka integrada, que se utiliza en este ejemplo sin modificaciones.
La plantilla de evento es la siguiente:
{ "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" }] } - Haga clic en Test. Se muestra el resultado de la prueba de función.
