Adatok begyűjtése az Apache Kafkától

Ez része a Tanulási út: Kezdje el az IBM Streams használatát.

Összegzésként

Ebben a fejlesztői kódmintában végigvezetjük az Apache Kafka által működtetett streaming alkalmazás létrehozásának alapjain, amely az egyik legnépszerűbb nyílt forráskódú elosztott esemény-streaming platform, amelyet valós idejű adatfolyam- és adatfolyam-alkalmazások létrehozására használnak. Az alkalmazás IBM Streams segítségével készül az IBM Cloud Pak® for Data rendszeren.

Leírás

Ebben a mintában végigvezetjük az Apache Kafka által működtetett streaming alkalmazás létrehozásának alapjain. Alkalmazásunk az IBM Streams használatával készül az IBM Cloud Pak for Data rendszeren. Az IBM Streams beépített IDE-t (Streams Flows) biztosít, amely lehetővé teszi egy streaming alkalmazás vizuális létrehozását. Az IBM Cloud Pak for Data platform további támogatást nyújt, például több adatforrással való integrációt, beépített elemzést, Jupyter Notebookokat és gépi tanulást.

Apache Kafka szolgáltatásunkhoz IBM Event Streams szolgáltatást használunk az IBM Cloudon, amely egy nagy áteresztőképességű üzenetbusz, amely a Kafka platformra épül. A következő példákban a kattintási adatfolyamok forrásaként és célpontjaként is bemutatjuk – az online vásárlási webhelyek böngészése során leadott felhasználói kattintásokból származó adatok.

Folyik

1. A felhasználó streaming alkalmazást hoz létre az IBM Streamsben.
2. A streaming alkalmazás a Kafka szolgáltatást használja az IBM Event Streams szolgáltatáson keresztül az üzenetek küldésére/fogadására.
3. A Jupyter notebook az IBM Streams alkalmazásból jön létre.
4. A felhasználó futtatja a streaming alkalmazást a Jupyter notebookban.
5. A Jupyter notebook az IBM Event Stream szolgáltatáson keresztül éri el a Kafka szolgáltatást üzenetek küldéséhez/fogadásához.

Utasítás

Készen áll az indulásra? A README elmagyarázza a lépéseket:

1. A repo klónozása
2. Provison eseményfolyamok az IBM Cloudon
3. Hozzon létre minta Kafka konzol Python alkalmazást
4. Adja hozzá az IBM Streams szolgáltatást a Cloud Pak for Data szolgáltatáshoz
5. Hozzon létre egy új projektet a Cloud Pak for Data szolgáltatásban
6. Hozzon létre Streams Flow-t a Cloud Pak for Data szolgáltatásban
7. Hozzon létre egy Streams Flow-t Kafka forrásként
8. Jegyzetfüzet létrehozásához használja a Streams Flow opciót
9. Futtassa a generált Streams Flow jegyzetfüzetet

Ez a minta része a Tanulási út: Kezdje el az IBM Streams használatát. Ha folytatni szeretné a sorozatot, és többet szeretne megtudni az IBM Streamsről, tekintse meg a kódmintát, melynek címe Készítsen streamelő alkalmazást Python API segítségével.

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