Vnesite podatke Apacheja Kafke

To je del Učna pot: Začnite z IBM Streams.

Povzetek

V tem vzorcu kode razvijalca vas vodimo skozi osnove ustvarjanja pretočne aplikacije, ki jo poganja Apache Kafka, ena izmed najbolj priljubljenih odprtokodnih distribuiranih platform za pretakanje dogodkov, ki se uporablja za ustvarjanje aplikacij za prenos podatkov v realnem času in aplikacij za pretakanje. Aplikacija bo izdelana z uporabo IBM Streams na IBM Cloud Pak® for Data.

Opis

V tem vzorcu vas popeljemo skozi osnove ustvarjanja aplikacije za pretakanje, ki jo poganja Apache Kafka. Naša aplikacija bo zgrajena z uporabo IBM Streams na IBM Cloud Pak for Data. IBM Streams ponuja vgrajen IDE (Streams Flows), ki omogoča vizualno ustvarjanje aplikacije za pretakanje. Platforma IBM Cloud Pak for Data ponuja dodatno podporo, kot je integracija z več viri podatkov, vgrajena analitika, prenosniki Jupyter in strojno učenje.

Za našo storitev Apache Kafka bomo uporabljali IBM Event Streams na IBM Cloud, ki je visoko zmogljivo vodilo za sporočila, zgrajeno na platformi Kafka. V naslednjih primerih jih bomo prikazali kot vir in cilj podatkov o toku klikov - podatke, zajete s kliki uporabnikov med brskanjem po spletnih mestih za spletno nakupovanje.

Pretok

1. Uporabnik ustvari aplikacijo za pretakanje v IBM Streams.
2. Aplikacija za pretakanje uporablja storitev Kafka prek IBM Event Streams za pošiljanje / prejemanje sporočil.
3. Prenosnik Jupyter je ustvarjen iz aplikacije IBM Streams.
4. Uporabnik zažene aplikacijo za pretakanje v zvezku Jupyter.
5. Prenosni računalnik Jupyter dostopa do storitve Kafka prek IBM Event Streams za pošiljanje / prejemanje sporočil.

navodila

Ste pripravljeni za začetek? The README pojasnjuje korake za:

1. Klonirajte repo
2. Priprava dogodkovnih tokov na IBM Cloud
3. Ustvarite vzorec aplikacije Kafka konzole Python
4. Dodajte storitev IBM Streams v Cloud Pak for Data
5. Ustvarite nov projekt v Cloud Pak za podatke
6. Ustvarite tok tokov v Cloud Pak za podatke
7. Ustvarite tok tokov s Kafko kot virom
8. Za ustvarjanje zvezka uporabite možnost Streams Flow
9. Zaženite ustvarjeni zvezek Streams Flow

Ta vzorec je del Učna pot: Začnite z IBM Streams. Če želite nadaljevati serijo in izvedeti več o IBM Streams, si oglejte vzorec kode z naslovom Zgradite aplikacijo za pretakanje z uporabo API-ja Python.

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