Apache Kafka'dan veri alın

Bu bir parçası Öğrenme yolu: IBM Streams'i kullanmaya başlayın.

Özet

Bu geliştirici kodu modelinde, gerçek zamanlı veri ardışık düzeni ve akış uygulamaları oluşturmak için kullanılan en popüler açık kaynaklı dağıtılmış olay akışı platformlarından biri olan Apache Kafka tarafından desteklenen bir akış uygulaması oluşturmanın temelleri konusunda size rehberlik ediyoruz. Uygulama, IBM Cloud Pak® for Data üzerinde IBM Streams kullanılarak oluşturulacaktır.

Açıklama

Bu modelde, Apache Kafka tarafından desteklenen bir akış uygulaması oluşturmanın temellerini size açıklıyoruz. Uygulamamız, IBM Cloud Pak for Data üzerinde IBM Streams kullanılarak oluşturulacaktır. IBM Streams, görsel olarak bir akış uygulaması oluşturmanıza olanak tanıyan yerleşik bir IDE (Streams Flows) sağlar. IBM Cloud Pak for Data platformu, birden çok veri kaynağıyla bütünleştirme, yerleşik analitik, Jupyter Not Defterleri ve makine öğrenimi gibi ek destek sağlar.

Apache Kafka hizmetimiz için, Kafka platformunda oluşturulmuş yüksek verimli bir mesaj veri yolu olan IBM Cloud üzerinde IBM Event Streams kullanacağız. Aşağıdaki örneklerde, bunu tıklama akışı verilerinin hem kaynağı hem de hedefi olarak göstereceğiz - çevrimiçi alışveriş web sitelerinde gezinirken kullanıcı tıklamalarından elde edilen veriler.

akış

1. Kullanıcı, IBM Streams'te akış uygulaması oluşturur.
2. Akış uygulaması, iletileri göndermek / almak için IBM Event Streams aracılığıyla Kafka hizmetini kullanır.
3. Jupyter not defteri, IBM Streams uygulamasından oluşturulur.
4. Kullanıcı Jupyter not defterinde akış uygulamasını yürütür.
5. Jupyter not defteri, mesaj göndermek / almak için IBM Event Streams aracılığıyla Kafka hizmetine erişir.

talimatlar

başlamaya hazır mısın? README aşağıdaki adımları açıklar:

1. Depoyu klonlayın
2. IBM Cloud'da Olay Akışlarını Sağlayın
3. Örnek Kafka konsolu Python uygulaması oluşturun
4. IBM Streams hizmetini Cloud Pak for Data'ya ekleyin
5. Cloud Pak for Data'da yeni bir proje oluşturun
6. Veri için Cloud Pak'ta bir Akış Akışı Oluşturun
7. Kaynak olarak Kafka ile bir Akış Akışı oluşturun
8. Bir not defteri oluşturmak için Akış Akışı seçeneğini kullanın
9. Oluşturulan Akış Akışı not defterini çalıştırın

Bu desen, Öğrenme yolu: IBM Streams'i kullanmaya başlayın. Diziye devam etmek ve IBM Streams hakkında daha fazla bilgi edinmek için, başlıklı bir kod kalıbına bakın. Python API kullanarak bir akış uygulaması oluşturun.

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