Nhập dữ liệu từ Apache Kafka

Nút nguồn: 747576

Đây là một phần của Lộ trình học tập: Bắt đầu với IBM Streams.

Tổng kết

Trong mẫu mã dành cho nhà phát triển này, chúng tôi sẽ hướng dẫn bạn những kiến ​​thức cơ bản về cách tạo một ứng dụng phát trực tuyến được cung cấp bởi Apache Kafka, một trong những nền tảng phát trực tuyến sự kiện phân tán mã nguồn mở phổ biến nhất được sử dụng để tạo các ứng dụng phát trực tuyến và đường dẫn dữ liệu thời gian thực. Ứng dụng sẽ được xây dựng bằng cách sử dụng Luồng IBM trên IBM Cloud Pak® cho Dữ liệu.

Mô tả

Trong mẫu này, chúng tôi sẽ hướng dẫn bạn những kiến ​​thức cơ bản để tạo một ứng dụng phát trực tuyến được cung cấp bởi Apache Kafka. Ứng dụng của chúng tôi sẽ được xây dựng bằng cách sử dụng Luồng IBM trên IBM Cloud Pak cho Dữ liệu. IBM Streams cung cấp một IDE (Luồng luồng) tích hợp sẵn cho phép bạn tạo một ứng dụng phát trực tuyến một cách trực quan. Nền tảng IBM Cloud Pak cho dữ liệu cung cấp hỗ trợ bổ sung, chẳng hạn như tích hợp với nhiều nguồn dữ liệu, phân tích tích hợp, Sổ tay Jupyter và máy học.

Đối với dịch vụ Apache Kafka của chúng tôi, chúng tôi sẽ sử dụng Luồng sự kiện của IBM trên Đám mây của IBM, đây là một bus thông báo thông lượng cao được xây dựng trên nền tảng Kafka. Trong các ví dụ sau, chúng tôi sẽ hiển thị nó dưới dạng cả nguồn và mục tiêu của dữ liệu luồng nhấp chuột — dữ liệu được thu thập từ các lần nhấp của người dùng khi họ duyệt qua các trang web mua sắm trực tuyến.

Dòng chảy

flow

  1. Người dùng tạo ứng dụng phát trực tuyến trong IBM Streams.
  2. Ứng dụng phát trực tuyến sử dụng dịch vụ Kafka thông qua Luồng sự kiện của IBM để gửi/nhận tin nhắn.
  3. Máy tính xách tay Jupyter được tạo từ ứng dụng IBM Streams.
  4. Người dùng thực thi ứng dụng phát trực tuyến trong sổ ghi chép Jupyter.
  5. Máy tính xách tay Jupyter truy cập dịch vụ Kafka thông qua Luồng sự kiện của IBM để gửi/nhận tin nhắn.

Hướng Dẫn

Sẵn sàng để bắt đầu? Các README giải thích các bước để:

  1. Sao chép repo
  2. Cung cấp Luồng sự kiện trên Đám mây của IBM
  3. Tạo ứng dụng Python của bảng điều khiển Kafka mẫu
  4. Thêm dịch vụ IBM Streams vào Cloud Pak cho dữ liệu
  5. Tạo một dự án mới trong Cloud Pak cho dữ liệu
  6. Tạo Luồng luồng trong Cloud Pak cho dữ liệu
  7. Tạo luồng Luồng với Kafka làm nguồn
  8. Sử dụng tùy chọn Luồng luồng để tạo sổ ghi chép
  9. Chạy sổ ghi chép Luồng được tạo

Mô hình này là một phần của Lộ trình học tập: Bắt đầu với IBM Streams. Để tiếp tục loạt bài này và tìm hiểu thêm về IBM Streams, hãy xem mẫu mã có tiêu đề Xây dựng ứng dụng phát trực tuyến bằng API Python.

Nguồn: https://developer.ibm.com/patterns/add-event-streams-and-a-db-in-python-to-clickstream/

Dấu thời gian:

Thêm từ Nhà phát triển IBM