Использование Kafka Trigger

Прежде чем создавать Kafka trigger, убедитесь, что подготовили следующее:

• Вы создали функцию в FunctionGraph. Для получения подробной информации см. Creating and Initializing a Function.
• Вы включили доступ VPC для функции. Для получения подробной информации см. Configuring VPC Access.
• Вы создали Kafka instance. Для получения подробной информации см. Creating a Kafka Instance.
• Вы создали тему в Kafka instance. Для получения подробной информации см. Creating a Topic.

1. Войдите в консоль FunctionGraph и выберите Functions > Function List в панели навигации.
2. Нажмите функцию HelloWorld.
3. Выберите Configuration > Triggers и нажмите Create Trigger.
4. Установите следующие параметры:
   • Trigger Type: выберите Distributed Message Service for Kafka (Kafka).
   • Instance: Выберите Kafka premium instance.
   • Topic: Выберите тему Kafka premium instance.
   • Batch Size: Установите количество сообщений, извлекаемых из темы каждый раз.
   • Username: Введите имя пользователя инстанса, если для него включён SSL.
   • Password: Введите пароль инстанса, если для него включён SSL.

5. Нажмите OK.
   Note

   После включения доступа VPC необходимо настроить соответствующие разрешения подсети для группы безопасности Kafka. Подробности о том, как включить доступ VPC, см. Configuring VPC Access.

1. Войдите в консоль FunctionGraph и выберите Functions > Function List в панели навигации.
2. Нажмите функцию HelloWorld.
3. На странице сведений о функции нажмите вкладку Code и выберите Configure Test Event.
4. Установите параметры, описанные в Table 1, и нажмите Save.
   Table 1 Информация о тестовом событии

   Параметр	Описание
   Настройте тестовое событие	Вы можете выбрать создание тестового события или редактирование существующего. Используйте параметр по умолчанию Create new test event.
   Шаблон события	Выберите DMS (for Kafka), чтобы использовать встроенный шаблон события Kafka.
   Имя события	Имя события может содержать от 1 до 25 символов и должно начинаться с буквы и заканчиваться буквой или цифрой. Допускаются только буквы, цифры, символы подчеркивания (_) и дефисы (-). Например, kafka-123test.
   Данные события	Система автоматически загружает встроенный шаблон события Kafka, который используется в этом примере без изменений.

   Note

   Шаблон события выглядит следующим образом:

   {
   	"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"
   	}]
   }
   
   

5. Нажмите Test. Отображается результат теста функции.