Does Redis Stack change the database game? Redis with superpowers! 🚀🔥 - YouTube

Was ist los, Leute, Redis hat gerade eine neue Datenbank namens Redis Stack angekündigt, und ich habe sie bekommen

frühen Zugriff, um damit herumzuspielen und meine Vorschläge zu machen, dies sind die gleichen Redis, die Sie kennen

und Liebe, aber mit Superkräften, die richtige Superkräfte sind, fügt es json search time series graph and hinzu

probabilistische Datenstrukturen zu oss redis können Sie nehmen und buchstäblich ersetzen

Ihr regelmäßiger Redis oss Ich habe diese Aktienbeobachtungslisten-App erstellt, um sie zu überprüfen, und ich muss sagen, dass ich es war

Ich bin wirklich beeindruckt davon, lassen Sie mich die Details durchgehen. Das Erstellen einer Echtzeitanwendung kann sehr sein

knifflig und es erfordert oft, dass Sie Daten in mehreren verschiedenen Formaten speichern, aber wussten Sie das schon?

redis Stack macht redis zu einer multimodalen Datenbank und unterstützt viele der Funktionen, die Sie benötigen

alles in einer einzigen Datenbank, wodurch Sie Zeit sparen und die Komplexität bei der Verwendung reduzieren

Datenbanken von mehreren Anbietern Ich habe hier die Beispielanwendung zum Tracking erstellt

eine Aktienbeobachtungsliste unter der Haube speichert Daten auf verschiedene Weise mit Redis Stack als

Primary Database und Message Broker verwende ich nicht nur einige grundlegende Datentypen wie Sets und Hashes

aber ich speichere auch json-dokumente zeitreihendaten und sogar einige probabilistische daten, die ich auch bin

Verwenden von Pub Sub zum Kommunizieren von Informationen zwischen einigen verschiedenen Mikrodiensten in Echtzeit mehr dazu

Lassen Sie uns später einmal in das eintauchen, was Sie im Mittelpunkt dieser App sehen

In der Beobachtungsliste können Sie hier sehen, dass ich eine Reihe beliebter Aktiensymbole beobachte, die ich sogar kann

Suche nach mehr, wenn ich will, also gehe ich einfach rein und tippe bac ein und du kannst mehrere verschiedene sehen

Börsenticker hier und ich kann diese bei Bedarf zu meiner Beobachtungsliste hinzufügen, indem ich einfach darauf klicke

Ich kann sie auch entfernen, wenn ich möchte, und auf der rechten Seite dieser Karte können Sie sie sehen

die Handelsinformationen in Echtzeit, sodass Sie den neuesten Handel von jeder Aktie auf der rechten Seite sehen

Seite der Seite sehen Sie diese Karte namens Trending Stocks, die eine Liste mit den meisten anzeigt

Häufig gehandelte Aktien in meiner Beobachtungsliste werden in letzter Minute jede Minute zurückgesetzt und verfolgt

der Anzahl der Trades, die innerhalb dieser Minute stattfinden, zeigt unten auf der Seite Informationen

Je nachdem, welche Aktie Sie in Ihrer Beobachtungsliste auswählen, können Sie auf verschiedene Symbole und die Uhr klicken

Liste zum Ändern der angezeigten Informationen. Das Diagramm wird mithilfe der in Echtzeit aktualisiert

alpaca api Die Zahl oben links im Diagramm zeigt den letzten Handelspreis sowie das Delta

zwischen dem letzten Handel und dem Schlusskurs der vorherigen Minute, den ich jede Minute erhalte

einen neuen Schlusskurs von Alpaca und aktualisieren Sie dieses Diagramm auf der rechten Seite sehen Sie die neuesten Nachrichten

Das sind Neuigkeiten, die von der Alpaka-API über die bestimmte Aktie, die Sie gerade betrachten, abgerufen wurden

Lassen Sie uns aufschlüsseln, wie ich die Daten speichere, abrufe und verwalte, die zum Füllen des Bildschirms verwendet werden

die watchlist wird in redis als set gespeichert ein set macht am meisten sinn da es automatisch geht

Verhindert doppelte Symbole. Ich speichere auch Informationen zu jeder Aktie, wie z. B. den Namen

Sektorindustrie und eine Liste von Neuigkeiten in einem json-Dokument und redis Stack, in dem der Preis gespeichert ist

eine Zeitreihe mit den Zeitreihenfunktionen von Redis Stack, dies macht es einfach, die zu erhalten

der neueste Preis sehr schnell, wenn das Frontend die Beobachtungsliste anfordert, von der ich einige herunterhole

die Informationen aus dem JSON-Dokument sowie den letzten Handel für jedes Symbol in der Liste dann

Ich verwende einen Web-Socket, um Preisaktualisierungen zu erhalten. Die Trendliste verwendet den Top-k-Filter, der a ist

Funktion, die in den Redis-Stack integriert ist und automatisch eine Rangliste für Sie erstellt, wenn Trades eingehen

Von der Alpaka-API füge ich sie einfach dem Top-k-Filter hinzu und er lässt mich wissen, ob die Rangliste hat

geändert Das Diagramm verwendet Zeitreihendaten, die in Echtzeit von der Alpaka-API abgerufen werden

und im Redis-Stack als Zeitreihe gespeichert, wenn Sie Zeitreihendaten im Redis-Stack speichern

Es macht es Ihnen super einfach, die Daten über einen Datumsbereich abzufragen und die Daten zu aggregieren

Es eignet sich perfekt zum Speichern von Daten, die Sie in einem Diagramm visualisieren möchten, bei dem die Zeit auf der x-Achse aufgetragen ist

Die Nachrichtenliste hier wird mit der Alpaka-API auf dem neuesten Stand gehalten und in einem JSON-Dokument in gespeichert

Reddit Stack zusammen mit anderen Informationen über eine Aktie, damit Sie sehen können, dass diese App möglicherweise

Schau einfach auf das Frontend, hinter den Kulissen ist viel los und das Ganze

wird von Redis Stack betrieben. Schauen wir uns nun ein Architekturdiagramm für diese Anwendung an, damit Sie es können

Wenn Sie sich dieses Architekturdiagramm ansehen, können Sie ein Gefühl dafür bekommen, wie alle Teile zusammenpassen

links drüben mit der Frontpartie ist die Frontpartie zuständig, die wir uns gerade angeschaut haben

um alle Daten zu erhalten, die zum Füllen dieses Dashboards erforderlich sind, also die Zeitreiheninformationen

Um das Diagramm und die aktuellsten Aktienkurse zu füllen, füllt es auch die Beobachtungsliste

und es erhält auch die Trendaktien und die Nachrichten über die Aktien, an denen Sie interessiert sind

Außerdem verwendet es einen Websocket mit dem API-Dienst, um Echtzeit-Updates zu erhalten

Aktienkursnachrichten und Trendaktien Als nächstes haben wir den API-Dienst, also ist der API-Dienst relativ

einfach, es erleichtert nur die Kommunikation zwischen dem Frontend und dem Redis-Stack

Es aktualisiert die Beobachtungsliste, wenn Sie eine Aktie zur Beobachtungsliste im Frontend hinzufügen oder daraus entfernen

Es fragt nach den Daten, die benötigt werden, um das Frontend zu füllen, also all die Daten, über die wir gerade gesprochen haben

die Beobachtungsliste die Rangliste die Zeitreihen und die Nachrichten es erhält auch Pub-Sub-Nachrichten

mit all den Leaderboard-Updates, neuen Trends und neuen Bars, die die Eröffnungs- und Schlusskurse sind

für eine Aktie erhält es die direkt von Redis und die werden tatsächlich von der generiert

Streaming-Dienst Der Streaming-Dienst kommuniziert also mit der Alpaka-API

um Echtzeit-Handelsinformationsleisten und -kurse zu erhalten und wenn ein neuer Kurs eingeht oder a

trade it aktualisiert die Rangliste mit Redis Bloom und der Top-k-Filter veröffentlicht dann Updates

Verwendung von Pub Sub mit Redis für Ranglistenänderungen oder immer dann, wenn es einen neuen Handel oder eine neue Bar gibt

verfügbar, abonniert es auch Aktualisierungen der Beobachtungsliste, also am Frontend, wenn Sie eine Aktie hinzufügen

Watch List Die API wird eine Nachricht an Redis senden, die besagt, dass die Watch List und die aktualisiert werden

Der Streaming-Dienst empfängt dann diese Nachricht und abonniert automatisch Updates von der

alpaca api für diese bestimmte Aktie jedes Mal, wenn ein neuer Handel oder Balken oder Code oder Nachrichten in den Markt kommen

Streaming-Dienst von Alpaca fügt es den Zeitreihen für die Aktien und der Watchlist hinzu

Was Sie hier im Wesentlichen sehen können, ist, dass Redis eine Menge von dem verarbeitet, was Sie sonst verwenden könnten

mehrere andere Tools, um dies zu tun, und Sie können damit nicht nur Daten in mehreren verschiedenen Formaten speichern

Mit Redis Stack können Sie jedoch auch Pub Sub verwenden, um zwischen Microservices zu kommunizieren

Ich bin mir sicher, dass es Sie schon jetzt juckt, sich etwas Code anzusehen, um zu verstehen, wie die Anwendung aufgebaut ist

Anstatt Ihnen den gesamten Code zu zeigen, für den Sie möglicherweise mehrere Stunden benötigen, um ihn gründlich durchzugehen

Ich werde einige spezifische Bereiche hervorheben, die interessant sind, wenn Sie am Lernen interessiert sind

Den gesamten Code können Sie sich in der Beschreibung unterhalb dieses Videos anschauen

Code können Sie sehen, dass ich einen API-Dienst, einen Stream-Dienst und einen UI-Dienst habe, für den der UI-Dienst bestimmt ist

Das Frontend, das wir uns gerade angesehen haben. Ich werde Ihnen nicht zu viel vom Frontend-Code zeigen

weil es anderen Anwendungen, die Sie vielleicht gebaut haben, ziemlich ähnlich ist, aber ich werde erwähnen, dass es so ist

Verwenden von tailwind css charge.js und next.js, also ist es eine sehr typische Front-End-next.js-Anwendung, die

Ruft einfach eine API auf, um alle Daten zu erhalten, aber schauen wir uns an, wie die API aussieht, wie ich die API geschrieben habe

Verwenden von Python und Fast API sowie Redis Ohm für die Kommunikation mit Redis Stack, also das erste

Zwei Routen hier sind die Beobachtungsliste, mit der Sie Aktien beobachten und nicht beobachten können, also Aktien hinzufügen und entfernen können

Von Ihrer Beobachtungsliste verwende ich ein Redis-Set, um Ihre Beobachtungsliste im Auge zu behalten

Ganz einfach, weil Du Duplikate automatisch vermeiden kannst, die nächste Route ist einfach so

Holen Sie sich die Beobachtungsliste, was es tut, es greift den Satz aus Redis heraus und verwendet dann Redis

ohm, um alle json-Dokumente zu erhalten, bei denen das Symbol für das json-Dokument in meiner Beobachtungsliste ist this

Lassen Sie mich einige Informationen vorbringen, wie z. B. die Nachrichten und einige andere Informationen über die Aktie

Eine andere Route wird gesucht, daher verwendet diese redis-Suche definierten Bestand, also wenn Sie die eingeben

Formular in Ihrer Beobachtungsliste im Frontend, sobald Sie eine bestimmte Anzahl von Zeichen erreicht haben i

Beginnen Sie mit der Suche nach Aktiensymbolen. Dies verwendet Redis Search und Redis Ohm. Diese Route dient dazu, alle zu erhalten

Die Balken in den letzten 30 Minuten, also was ich mit Balken meine, ist, dass die Alpaka-API Ihnen das gibt, was genannt wird

Bars, die einen hohen Preis, einen niedrigen Preis, ein Volumen, einen Eröffnungspreis und einen Schlusspreis innerhalb eines bestimmten Bereichs haben

Zeitraum, also schaue ich mir die letzten 30 Minuten Balken an und diese Runde einfach nur

Geben Sie ein Aktiensymbol an und es gibt die Balken für Sie zurück. Die nächste Route gibt Ihnen ein Individuum

trade, sodass Sie sowohl den letzten Trade für ein bestimmtes Symbol als auch den Preis dieses Trades erhalten

dieser Routen verwenden Redis-Zeitreihen, die Teil des Redis-Stacks sind und Zeitreihen speichern

Daten, damit Sie sie einfach über einen Bereich abfragen können, wie wir es hier tun, oder um die neuesten zu erhalten

Preis, was wir hier tun, dies ist die Trendroute, also wird uns dies die Liste geben

Trendaktien erinnern sich, dass diese Aktien basierend auf der Handelshäufigkeit tendieren, also ist das alles

schaut sich den Top-k-Filter an und bittet ihn, uns die Liste zu geben, die Redis Bloom verwendet, die Teil ist

von redis stack sehen die nächsten Dinge vielleicht wie Routen aus, aber sie sind eigentlich Web-Sockets

Ich habe hier einen trendigen Aktien-Websocket, wo das Frontend sagen kann, hey, gib mir alle Updates

über Trendaktien und dies wird nur den Redis-Stack auf Nachrichten über die Trendaktien abhören

und Sie automatisch darüber informieren, dass es eine aktualisierte Trendliste gibt, die nächste ist ähnlich, aber

für Trades, damit Sie wissen, wann es einen neuen Trade gibt und der letzte für Barren ist

damit wir Sie wissen lassen, wenn es neue Balken am Frontend gibt, so aktualisieren wir alle Preise

Informationen und die Beobachtungsliste und so aktualisieren wir die Grafik, die es für die API gibt

Schauen wir uns jetzt den Streaming-Dienst an. Das erste, was wir uns für den Streaming-Dienst ansehen möchten

ist der Einstiegspunkt, der der Hauptpunkt pi ist, so dass dies wie die API in Python geschrieben ist

und es verwendet das Alpaka-SDK sowie Redis Stack in der Hauptschleife all das

Wir verbinden uns mit Alpaka und löschen die Trendaktien, also die Trendaktien

Schlüssel ist, was wir verwenden, um die Trendaktien mit redis bloom und top k zu verfolgen

Dann reserviert es die Trendaktien erneut und synchronisiert die Beobachtungsliste mit

Was auch immer sich zu diesem Zeitpunkt im Satz in Redis befindet, was Reserve Top k tut, ist, dass es nur diesen Schlüssel reserviert

zur Verwendung mit dem Top-k-Filter und wir sagen, behalten Sie den Überblick über die 12 am häufigsten gehandelten Aktien

und dann setzen wir auch einen Ablauf dieses Schlüssels auf 60 Sekunden. Der Grund dafür ist alle 60 Sekunden

Wir erstellen die Trendaktienliste neu, sodass Sie sie alle 60 Sekunden im Frontend sehen können

Okay, welche Aktien aktiv gehandelt werden, also verwenden wir Pub Sub, um zu verstehen, wann

Der Schlüssel für Trending Stocks ist abgelaufen, und wenn er abgelaufen ist, reservieren wir ihn und beginnen mit dem Neuaufbau

Die Liste hören wir auch auf die Beobachtungsliste, also wenn Sie sich in der API am Frontend erinnern

Sie können etwas zu Ihrer Beobachtungsliste hinzufügen oder entfernen, indem Sie die API einfach tun

aktualisiert das Set innerhalb von redis well hier werden wir uns diesen Watchlist-Key-Space anhören

und wann immer es aktualisiert wird, werden wir es synchronisieren, also lassen Sie uns eintauchen, wie das hier aussieht, wenn wir synchronisieren

Die Beobachtungsliste Wir erhalten im Grunde die Beobachtungsliste, die eine Reihe von Vergleichen durchführt und

Abmeldung von allem, was wir abbestellen und abonnieren müssen

Wir müssen auch abonnieren, der Rest hat alles mit Alpaka zu tun, also nennen wir Abo-Trades

Auf diese Weise hören wir die Alpaka-API in Echtzeit und erhalten Trades sowie Barren, die wir auch erhalten können

Initialisieren Sie eine Aktie, wenn wir müssen, und was dies tun wird, ist, dass es uns historische Trades gibt und

historische Balken über die Aktie und es werden auch die Zeitreihenschlüssel erstellt, die wir in Redis benötigen

Stack, hier werden also alle Zeitreihen mit allen Trades über die letzte beliebige Zeit erstellt

Zeitraum, den wir entschieden haben, und ich glaube, ich habe entschieden, dass der Zeitraum der letzte sein würde, ich weiß nicht 30

Minuten oder so, und das war es hier drin. Der nächste Teil davon ist, was als eingehendes passiert

Trades und eingehende Bars kommen herein. Wenn eingehende Trades eingehen, fügen wir den Trade unserer Zeitreihe hinzu

und dann fügen wir es auch zu unserem Top-k hinzu und veröffentlichen dann ein Update, in dem wir sagen, dass wir es aktualisiert haben

das Top-k, also gibt es einen neuen Handel im Top-k, der unsere API anweist, die Top-k-Liste zu aktualisieren

am Frontend und wenn Sie sich erinnern, gibt es einen Web-Socket, auf den das Frontend hören kann

um Updates zu diesen Trendaktien zu erhalten, so dass der Nachrichtenfluss hier ist, dass ein eingehender Handel von Alpaka kommt

Dann veröffentlichen wir eine Nachricht, in der es heißt, dass wir die Trades aktualisiert und den Trend aktualisiert haben

Aktienliste, dann empfängt die API diese Nachricht und benachrichtigt das Front-End, falls vorhanden

alle erforderlichen Änderungen und ich habe Ihnen nur einen kleinen Einblick in den gesamten Code gezeigt, der hier enthalten ist

Ich wollte Ihnen einige spezifische Dinge zeigen, damit Sie ein Gefühl dafür bekommen, wie das alles funktioniert

Teile passen innerhalb dieser Anwendung zusammen, aber das nächste, was ich Ihnen zeigen möchte, ist

Wie das in Redis Insight aussieht In Redis Insight können Sie sehen, wie wir eine Reihe von JSON-Dokumenten haben

die jede Aktie darstellen, also habe ich eine Reihe von Daten direkt von der NASDAQ gezogen, um sie zu füllen

All diese Informationen lassen Sie uns einen Blick auf die Beobachtungsliste werfen, damit die Beobachtungsliste ein Set ist und Sie sehen können, dass sie vorhanden ist

alle Artikel, die auf unserer Beobachtungsliste im Frontend vertreten waren, so können wir das

um zu verfolgen, was wir sehen, und um Dinge aus diesem Set hinzuzufügen oder zu entfernen, wenn wir beides tun

sie nicht mehr sehen wollen oder mit, wenn wir eine neue Aktie sehen wollen

Schauen wir uns jetzt etwas auf unserer Beobachtungsliste an, z. B. Apple. Wenn ich also nach Apple filtere, sehen Sie

Wir haben eine Reihe verschiedener Datenstrukturen für Apple selbst. Die erste ist diese JSON

Dokument, so dass es Informationen wie die Marktkapitalisierung, den Namen Apple-Stammaktien speichert

der Branche und der Industrie hat es auch eine eingebettete Liste von Nachrichtenartikeln, also ist dies der Ort

Im Frontend zeigen wir Ihnen all diese Artikellisten und lassen Sie dann klicken

und gehen Sie zu ihnen, das ziehen wir aus der Alpaka-API, damit neue Nachrichtenartikel eingehen

Wir aktualisieren dieses JSON-Dokument mit dem Artikel, in dem wir auch eine Reihe von anderen speichern

Zeitreihen in Bezug auf Notierungen, Trades und Balken, Sie können die Daten hier nicht sehen, aber schauen wir uns an, was

Es sieht so aus, als würden wir den neuesten Handel von Apple erhalten. Wir werden also den Befehl ts.get verwenden

um den neuesten Preis des Apfelhandels zu erhalten, so dass der erste Wert, der zurückgegeben wird, der Zeitstempel ist

und der zweite ist der Preis, und was wir tun, ist, diesen Bereich abzufragen, um ihn zu füllen

Das Diagramm am Frontend ist der Befehl dafür ts.range und was ich hier tun werde, ist, a anzugeben

from timestamp und a to timestamp, um mehrere verschiedene Werte zu erhalten, sodass wir am Frontend eine Liste erhalten

von Schlüssel-Wert-Paaren, bei denen der Schlüssel der Zeitstempel und der Wert der Aktienkurs ist, also hoffentlich vorbei

Jetzt bekommen Sie ein Gefühl dafür, wie leistungsfähig Redis Stack ist und wie es Redis in eine multimodale Datenbank verwandelt

die Sie verwenden können, um mehrere Technologien zu ersetzen, die Sie normalerweise in Echtzeit verwenden würden

Anwendung hier Unsere gesamte Anwendung wird von Anfang bis Ende von Redis Stack unterstützt. Wir sehen uns dann