Ich habe eine Anforderung: Wenn ein neuer Kommentar gepostet wird, möchte ich die Besitzer-ID aller vorherigen Kommentare abrufen und eine Benachrichtigung senden.Ermitteln, dass ein neuer Datensatz zur Cassandra-Tabelle hinzugefügt wurde
Problem hier ist, wie ich weiß, dass ein neuer Kommentar zu Cassandra Tabelle hinzugefügt wurde. Was wird die Lösung für diese Art von Anforderung?
Wenn Sie nur Cassandra verwenden möchten, ohne Änderungen, ist es unmöglich. Mit Änderungen, haben Sie drei Möglichkeiten:
Sie cassandra als eingebetteter Dienst in Java verwenden kann. Hier ist eine einfache und kurze Anleitung: http://prettyprint.me/prettyprint.me/2010/02/14/running-cassandra-as-an-embedded-service/index.html
Sie können einen Wrapper für Ihre Cassandra-Verbindung erstellen. Eine Anwendung, die die Cassandra-Verbindung verarbeitet und über die API für Ihre andere Anwendung verfügbar ist.
Cassandra hat eine Triggerfunktionalität. (Nie benutzt und nie gehört, dass jemand es benutzt)
Ich bevorzuge die zweite Lösung. Hier sind die Gründe warum:
Es ist einfacher zu erstellen.
Sie können alle Ihre Ansichten in dieser Anwendung verarbeiten.
Sie können die Eingabe bestätigen, Beziehungen zu lösen, Logging-Daten usw.
Sie können einfach den neuen hinzugefügt Kommentar drücken oder eine andere Nachrichtenwarteschlange zu KAFKA.
Dies könnte eine Einrichtung sein:
einen Kommentar erstellen -> rufen ein Back-End-api -> rufen Sie die cassandra Datenbank-Schnittstelle -> drücken, um eine neue Nachricht zu kafka -> die Daten an alle kafka senden Consumer
Das klingt wie etwas, was Sie in Ihrer Anwendung tun sollten, Ereignis ausgelöst durch Benutzer einen Kommentar, nicht das Ereignis der Tabelle wird aktualisiert .. –
Cassandra 2.0 und neuere Version unterstützt [Auslöser] (http: // www. datastax.com/dev/blog/whats-new-in-cassandra-2-0-prototype-triggers-support) was Ihnen helfen würde ... –
ist Trigger Idle für eine Situation wo ver Gibt es häufige Schreibvorgänge? – manish