Это часть Путь обучения: начать работу с IBM Streams.
Обзор
В этом шаблоне кода разработчика мы познакомим вас с основами создания потокового приложения на базе Apache Kafka, одной из самых популярных распределенных платформ потоковой передачи событий с открытым исходным кодом, используемых для создания конвейера данных в реальном времени и потоковых приложений. Приложение будет создано с использованием IBM Streams в IBM Cloud Pak® for Data.
Описание
В этом шаблоне мы познакомим вас с основами создания потокового приложения на базе Apache Kafka. Наше приложение будет создано с использованием IBM Streams в IBM Cloud Pak for Data. IBM Streams предоставляет встроенную среду IDE (Streams Flows), которая позволяет визуально создавать потоковые приложения. Платформа IBM Cloud Pak for Data обеспечивает дополнительную поддержку, такую как интеграция с несколькими источниками данных, встроенная аналитика, Jupyter Notebooks и машинное обучение.
Для нашей службы Apache Kafka мы будем использовать IBM Event Streams в IBM Cloud, которая представляет собой шину сообщений с высокой пропускной способностью, построенную на платформе Kafka. В следующих примерах мы покажем его и как источник, и как цель данных о потоках кликов - данные, полученные в результате кликов пользователей, когда они просматривали веб-сайты онлайн-покупок.
Поток
- Пользователь создает потоковое приложение в IBM Streams.
- Приложение Streaming использует службу Kafka через IBM Event Streams для отправки / получения сообщений.
- Блокнот Jupyter создается из приложения IBM Streams.
- Пользователь запускает потоковое приложение в блокноте Jupyter.
- Блокнот Jupyter обращается к сервису Kafka через IBM Event Streams для отправки / получения сообщений.
инструкции
Готовы начать? В README объясняет шаги, чтобы:
- Клон репо
- Предоставление потоков событий в IBM Cloud
- Создать образец приложения Python для консоли Kafka
- Добавить сервис IBM Streams в Cloud Pak for Data
- Создайте новый проект в Cloud Pak for Data
- Создайте поток потоков в Cloud Pak для данных
- Создайте поток потоков с Kafka в качестве источника
- Используйте параметр Streams Flow для создания записной книжки
- Запустите созданную записную книжку Streams Flow
Эта модель является частью Путь обучения: начать работу с IBM Streams. Чтобы продолжить серию и узнать больше об IBM Streams, ознакомьтесь с шаблоном кода под названием Создайте потоковое приложение с помощью Python API.
Источник: https://developer.ibm.com/patterns/add-event-streams-and-a-db-in-python-to-clickstream/
