Kafka Streams и ksqlDB: данные в реальном времени [Митч Сеймур] (pdf) читать постранично, страница - 5

288
Учебный проект.......................................................................................................................... 289
Установка ksqlDB.................................................................................................................. 289
Запуск сервера ksqlDB....................................................................................................... 290
Предварительное создание тем................................................................................... 291
Использование интерфейса командной строки ksqlDB CLI............................. 291
Заключение................................................................................................................................... 294

12  Оглавление
Глава 9. Интеграция данных в ksqlDB..................................................................................... 295
Обзор Kafka Connect................................................................................................................. 296
Внешняя и встроенная интеграция с Connect.............................................................. 297
Внешняя интеграция.......................................................................................................... 298
Встроенная интеграция.................................................................................................... 299
Настройка рабочих процессов Connect.......................................................................... 300
Конвертеры и форматы сериализации..................................................................... 302
Учебный проект.......................................................................................................................... 304
Установка коннекторов........................................................................................................... 305
Создание экземпляров коннекторов в ksqlDB...................................................... 306
Вывод списка коннекторов............................................................................................. 308
Получение описаний коннекторов............................................................................. 309
Удаление коннекторов...................................................................................................... 310
Проверка коннектора-источника....................................................................................... 310
Взаимодействие с кластером Kafka Connect напрямую........................................... 311
Анализ управляемых схем..................................................................................................... 312
Заключение................................................................................................................................... 313
Глава 10. Основы потоковой обработки с ksqlDB............................................................. 314
Учебный проект: мониторинг изменений в Netflix..................................................... 315
Настройка проекта.................................................................................................................... 317
Исходные темы............................................................................................................................ 318
Типы данных................................................................................................................................. 319
Пользовательские типы.................................................................................................... 320
Коллекции...................................................................................................................................... 322
Создание исходных коллекций..................................................................................... 323
Оператор WITH..................................................................................................................... 325
Работа с потоками и таблицами........................................................................................... 326
Вывод списка потоков и таблиц.................................................................................... 326
Получение описаний потоков и таблиц.................................................................... 327
Изменение потоков и таблиц......................................................................................... 328
Удаление потоков и таблиц............................................................................................. 329
Простые запросы........................................................................................................................ 329
Вставка значений................................................................................................................. 330
Простая выборка (временные push-запросы)....................................................... 331

Оглавление  13
Проекция................................................................................................................................. 333
Фильтрация............................................................................................................................ 333
Подстановочные знаки..................................................................................................... 334
Развертывание/упрощение сложных вложенных структур............................ 335
Условные выражения............................................................................................................... 336
COALESCE................................................................................................................................. 337
IFNULL....................................................................................................................................... 337
Оператор CASE...................................................................................................................... 337
Запись результатов обратно в Kafka (постоянные запросы).................................. 338
Создание производных коллекций............................................................................. 338
Все вместе...................................................................................................................................... 342
Заключение................................................................................................................................... 344
Глава 11. Продвинутая обработка потоков с ksqlDB....................................................... 345
Настройка проекта.................................................................................................................... 346
Инициализация окружения из файла SQL...................................................................... 346
Обогащение данных.................................................................................................................. 348
Соединения............................................................................................................................ 349
Оконные соединения............................................................................................................... 354
Агрегирование............................................................................................................................ 357
Основы