Erstellen Sie eine Echtzeit-Event-Pipeline für Millionen von Events

Moderne Anwendungen generieren einen konstanten Strom von Klicks, Transaktionen, Sensorwerten, API-Aufrufen und Protokollen.  Verwandeln Sie kontinuierliche, hochvolumige Streams in zuverlässige analytische Erkenntnisse. Diese Enterprise-Architektur vereinheitlicht Sammlung, Verarbeitung und Analyse und kombiniert dauerhafte Ingestion mit schnellen Abfragen für AdTech-, FinTech-, IoT- und Observability-Teams, die auf aktuelle Daten reagieren müssen.
[object Object]

Die beiden Engpässe bei einer Echtzeit-Event-Pipeline

Echtzeit-Event-Pipelines scheitern an einer von zwei Stellen: Events gelangen nicht zuverlässig durch die Ingestions-Schicht oder sie werden in der Plattform nie zu schnellen Abfragen. Dies sind getrennte Probleme, die unterschiedliche Tools erfordern, und wenn nur eines davon gelöst wird, stehen die Teams letztendlich mit teuren, fragilen Stacks da.

Ohne ein dauerhaftes Streaming-Rückgrat werden verteilte Datenproduzenten und Datenkonsumenten eng miteinander gekoppelt. Producer sind die Anwendungen, die Events generieren und an Kafka-Topics senden, während Consumer die Dienste sind, die diese Events lesen. Producer schreiben direkt in Warteschlangen, Datenbanken oder benutzerdefinierte Dienste, und wenn ein Consumer ausfällt oder verzögert, blockiert der Producer entweder oder beginnt, Events zu verwerfen.

Darüber hinaus sind PostgreSQL und ähnliche OLTP Public Cloud-Datenbanken für Vorgänge auf Zeilenebene konzipiert: Einfügen, Aktualisieren, Löschen. Sie sind nicht dafür ausgelegt, Milliarden von Zeilen zu scannen, über mehrere Dimensionen zu aggregieren oder Dashboards jede Minute zu aktualisieren. Mit wachsendem Event-Volumen dauern Abfragen, die früher in 200 ms zurückkehrten, mit der Zeit Sekunden, dann Dutzende von Sekunden und schließlich Minuten. Das System wird zum Engpass für Produktentscheidungen.
[object Object]

Betrieb mit Zuversicht auf Unternehmensebene

Die Echtzeit-Event-Pipeline umfasst Replikation, Backups und Überwachung
[object Object]
Kafka ermöglicht korrektes Streaming
[object Object]
ClickHouse unterstützt schnelle Analysen
[object Object]
Replikation, Backups und Überwachung
[object Object]
Europäische Regionen und Kontrollen zur Datensouveränität

Eine Referenzarchitektur: Apache Kafka + ClickHouse

Apache Kafka als Streaming-Backbone

Kafka fungiert als zentrales Nervensystem für Events. Producer schreiben Events in Topics, die logisch geordnet und über Broker partitioniert werden. Jede Partition kann unabhängig gelesen werden, wodurch Kafka den Durchsatz horizontal skaliert. Consumer-Gruppen lesen aus diesen Partitionen, und jeder Consumer in einer Gruppe ist für eine Teilmenge der Partitionen verantwortlich.

Partitionen sind der Schlüssel zum Durchsatz. Ein Topic mit mehr Partitionen kann mehr Schreibvorgänge und mehr Consumer parallel verarbeiten, bis zur Anzahl der Partitionen. Consumer-Gruppen ermöglichen eine erneute Wiedergabe (Replay). Schemas für Anwendungen werden typischerweise separat verwaltet, oft mit einer Schema Registry, sodass Producer und Consumer sich weiterentwickeln können, ohne sich gegenseitig zu beeinträchtigen. Die Events werden für einen konfigurierbaren Aufbewahrungszeitraum gespeichert, was Ihnen ein Zeitfenster gibt, Daten erneut abzuspielen, ohne sie von der Quelle neu verarbeiten zu müssen. Diese Nachhaltigkeit und kontinuierliche Entkopplung machen Kafka zu einem zuverlässigen Rückgrat für hochvolumige Ereignisströme.

ClickHouse als Echtzeit-OLAP-Ebene

ClickHouse ist eine spaltenorientierte, verteilte Datenbank, die für analytische Workloads konzipiert ist. Sie speichert Daten spaltenweise statt zeilenweise, was bedeutet, dass sie bei Abfragen irrelevante Spalten überspringen und Daten stark komprimieren kann. In Kombination mit ihrer Storage-Engine, die für sequenzielle Lesevorgänge und Prädikat-Pushdown optimiert ist, ermöglicht dies ClickHouse, Milliarden von Zeilen schnell zu scannen und aggregierte Ergebnisse in Millisekunden zurückzugeben. Neue Ereignisse können in Echtzeit aufgenommen werden, und ClickHouse kann sie mithilfe von materialisierten Sichten voraggregieren, die sich bei Dateneingang aktualisieren. Dies bedeutet kontinuierliche Dashboards und Warnmeldungen, ohne auf einen Batch-Job oder ein ETL-Fenster warten zu müssen. Die Datenbank ist für die horizontale Skalierung ausgelegt, wobei Knoten hinzugefügt werden, um die Speicher- und Rechenkapazität mit wachsendem Ereignisvolumen zu erhöhen.

Object Storage als gestufte Cold-Data-Ebene für alte Ereignisse

Nicht alle Daten müssen im Hot-Storage liegen; jedes Ereignis in ClickHouse auf lokalen Festplatten zu speichern, wird teuer und unnötig. Das gängige Muster besteht darin, ältere Daten in den OVHcloud Object Storage (S3-kompatibel)* auszulagern, während aktuelle Daten für schnelle Abfragen in ClickHouse verbleiben. Ereignisse, die älter als ein konfigurierter Schwellenwert sind, werden bei Bedarf abgefragt, wenn eine tiefere historische Analyse erforderlich ist. Dieser Ansatz reduziert die Kosten für die langfristige Aufbewahrung und bewahrt gleichzeitig die Möglichkeit, Abfragen über den gesamten Datensatz auszuführen. 

Für viele reale Verarbeitungsanwendungsfälle hält die Hot-Ebene (ClickHouse) Daten für Tage oder Wochen für Dashboards und Echtzeit-Warnmeldungen bereit, während die Cold-Ebene (OVHcloud Object Storage) Monate oder Jahre an Historie für Compliance, Audits und regelmäßige tiefgehende Analysen speichert. Diese Trennung hält die Betriebskosten vorhersehbar und ermöglicht es der Pipeline, zu skalieren, ohne an eine harte Obergrenze für den App-Speicher zu stoßen.


Die native Kafka-Engine-Integration in ClickHouse

Apache KafkaKafka ConnectClickHouse
Es gibt drei Hauptansätze: die native Kafka-Tabellen-Engine in ClickHouse, materialisierte Ansichten, die auf dieser Engine aufbauen, und Kafka Connect für die Anbindung an externe Systeme.

ClickHouse verfügt über eine integrierte Kafka-Tabellen-Engine, mit der Sie Kafka-Themen direkt abonnieren können. Sie definieren eine Tabelle mit der Kafka-Engine, geben den Themennamen, die Broker-Liste und die Consumer-Gruppe an, und ClickHouse beginnt, Ereignisse aus Kafka zu konsumieren, als wären sie Zeilen in einer regulären Tabelle. Dies ist eine direkte, native Integration, die keine zusätzliche Middleware erfordert. Die Kafka-Engine in ClickHouse ist für die Streaming-Ingestion konzipiert. Sie liest Datensätze aus dem Topic, analysiert sie gemäß dem von Ihnen angegebenen Format (JSON, Avro, Protobuf usw.) und stellt sie als Zeilen dar, die abgefragt oder in andere Tabellen eingefügt werden können.
Technisches Diagramm einer Echtzeit-Ereignis-Pipeline mit Apache Kafka im Zentrum, das Anwendungen, Datenbanken, nachgelagerte Plattformen und verbindet
Die Echtzeit-Ereignis-Pipeline sammelt Impression-, Klick- und Conversion-Streams, sobald sie auftreten. Kampagnenteams können das Pacing überwachen, Attributionssignale aktualisieren und ungewöhnliche Verkehrsmuster identifizieren, bevor zeitversetzte Batch-Berichte sie aufdecken. Unabhängige Ereignistypen bleiben für Untersuchungen und Neuberechnungen verfügbar.

Transaktionsereignisse speisen Live-Risikoindikatoren, Verhaltensprüfungen und operative Warnungen. Die Analysten können Konto-, Zahlungs- und Geräteaktivitäten zusammen untersuchen, was den Untersuchungsteams hilft, verdächtige Sequenzen zu erkennen und mit aktuellen Informationen zu reagieren, anstatt auf die geplante Verarbeitung zu warten.

Sensoren, vernetzte Geräte und Fahrzeuge erzeugen kontinuierliche Telemetriedaten. Die Pipeline erfasst Messwerte, Statusänderungen und Fehlersignale, wodurch die Teams in der Lage sind, den Gerätezustand zu bewerten, Flotten zu verfolgen und Betriebsbedingungen zu erkennen, die ein Eingreifen erfordern.

Logs, Metriken und Traces fließen zur schnellen Filterung und Korrelation Dienste-übergreifend in ClickHouse. Die Kafka-Tabellen-Engine liefert die Streaming-Brücke zu analytischen Tabellen, wo die Plattformteams Vorfälle untersuchen, Systemverhalten vergleichen und Dashboards unterstützen können, ohne für jeden Signaltyp separate Ingestionspfade auszuführen.
Die Echtzeit-Ereignis-Pipeline sammelt Impression-, Klick- und Conversion-Streams, sobald sie auftreten. Kampagnenteams können das Pacing überwachen, Attributionssignale aktualisieren und ungewöhnliche Verkehrsmuster identifizieren, bevor zeitversetzte Batch-Berichte sie aufdecken. Unabhängige Ereignistypen bleiben für Untersuchungen und Neuberechnungen verfügbar.

Eingehende Ereignisse für schnellere Entscheidungen gestalten

Wiederkehrende Messwerte voraggregieren

Materialisierte Ansichten berechnen kontinuierlich Summen, Raten und gruppierte Messwerte, während Ereignisse eintreffen, wodurch wiederholte Arbeit zur Abfragezeit reduziert wird.

Tabellen an Zugriffsmustern ausrichten

Ordnen Sie Daten nach Zeit und häufig gefilterten Dimensionen, damit bei Untersuchungen weniger irrelevante Datensätze gelesen werden.

Nur nützliche Felder lesen

Die Spaltenauswahl begrenzt das Scannen auf die Attribute, die für jedes Dashboard, jede Warnung oder jede explorative Abfrage erforderlich sind.

Aufbewahrung anhand der Nachfrage gestalten

Trennen Sie häufig abgefragte Datensätze von weniger aktiven Daten. Aufbewahrungsbewusste Tabellen helfen dabei, Analysen im Subsekundenbereich für operative Ansichten aufrechtzuerhalten und gleichzeitig Untersuchungen brauchbar zu halten, während die Historien wachsen.

Warten verursacht Kosten

LatenzETLTerraform
Wenn die App-Pipeline langsam oder unzuverlässig ist, sind die Konsequenzen messbar. Reaktionszeiten bei der Betrugserkennung dehnen sich von Sekunden auf Minuten aus, was im FinTech-Bereich direkt zu finanziellem Verlust und Reputationsschäden führt. Langsame Berichtszyklen blockieren Produktentscheidungen und zwingen die Teams dazu, sich auf Snapshots zu verlassen, die zum Zeitpunkt ihrer Überprüfung bereits veraltet sind. Um dies auszugleichen, beginnen die Teams damit, den Stack zu patchen. Benutzerdefinierte ETL-Jobs, manuell zusammengestellte Nachrichtenwarteschlangen und Berichtsansichten summieren sich zu einer Ad-hoc-Pipeline, die manuell gewartet werden muss. Die wirklichen Kosten sind nicht nur die unmittelbare Latenz. Es handelt sich um die operative Belastung, die technische Schuld und die Tatsache, dass das Team nicht an Echtzeitfunktionen arbeiten kann, weil es damit beschäftigt ist, die bestehende Pipeline am Laufen zu halten.
[object Object]

Legen Sie für jede Ebene eine klare Verantwortung fest

Streaming-Backbone

Puffern, ordnen und wiederholen Sie hochvolumige Ereignisströme, damit Producer unabhängig von Verarbeitungs- und Analyse-Workloads bleiben.

Analytische Bereitstellung

Stellen Sie aktuelle Ereignisse für schnelle operative Abfragen, Dashboards und Untersuchungen bereit, während Sie eine dedizierte Umgebung für analytische Anforderungen beibehalten.

Kalt-Daten-Ebene

Bewahren Sie ältere Historien außerhalb von leistungsorientiertem Speicher auf. Diese Trennung unterstützt den langfristigen Zugriff, ohne jedes Ereignis im heißen analytischen Pfad zu halten. Das gängige Muster besteht darin, ältere Daten in OVHcloud Object Storage einzustufen

Verwaltete Betriebsabläufe & Lieferung

OVHcloud verwaltet Replikation, Backups und Monitoring über die gesamte Service-Architektur hinweg. Die Teams können Ressourcen über das OVHcloud Kundencenter bereitstellen oder wiederholbare Umgebungen mit Terraform definieren. 

Stellen Sie in wenigen Minuten eine Echtzeit-Event-Pipeline bereit

Die Bereitstellung einer Echtzeit-Event-Pipeline auf OVHcloud dauert nur wenige Minuten. Sie stellen einen Managed Apache Kafka-Cluster und eine Managed ClickHouse-Instanz über das OVHcloud Kundencenter oder Terraform bereit, wobei Replikation, Backups und Monitoring standardmäßig aktiviert sind.

Für Teams, die Unterstützung bei der Dimensionierung des Stacks möchten, bietet OVHcloud direkten Zugang zu Dateninfrastruktur-Spezialisten, auch für Managed Databases for PostgreSQL, die Ihre aktuellen Ereignisvolumina und Abfragemuster bewerten und einen Kostenvergleich mit Ihrem bestehenden Stack erstellen können. Egal, ob Sie ein Data Engineer sind, der Ergebnisse für Milliarden von Zeilen in Echtzeit mit minimalem Infrastrukturaufwand benötigt, oder ein Head of Data, der sich eine geringere Betriebslast und vorhersehbare Cloud-Kosten wünscht, der verwaltete Stack beseitigt den betrieblichen Overhead und hält die Architektur gleichzeitig portabel und Open-Source.

*S3 ist eine eingetragene Marke von Amazon Technologies, Inc. OVHcloud Dienste werden in keinster Weise von Amazon Technologies, Inc. gesponsert oder befürwortet und stehen auch nicht mit dem Unternehmen in Verbindung.
OVHcloud_Cloud_Database_Main_600x400.png
Beginnen Sie den Aufbau von verlässlichen Echtzeit-Erkenntnissen
Es ist möglich, Kafka und ClickHouse selbst zu betreiben, aber das ist teuer in Bezug auf Engineering-Zeit und betriebliche Risiken. OVHcloud bietet sowohl Managed Apache Kafka als auch Managed ClickHouse als vollständig verwaltete Dienste an, wobei der Schwerpunkt auf auf europäischer Souveränität, vorhersehbaren Preisen und hoher Verfügbarkeit liegt. 
Entdecken Sie unsere Streaming-, Analyse- und Speicherdienste und verwandeln Sie dann hochvolumige Ereignisse in verlässliche, abfragbare Erkenntnisse, während Sie gleichzeitig den betrieblichen Aufwand reduzieren, um die zugrunde liegende Infrastruktur zu betreiben.
Mit dem Aufbau beginnen