Erstellen Sie einen Datenstream

Im ersten Schritt von Tutorial: Verarbeiten Sie Aktiendaten in Echtzeit mit KPL und KCL 1.x erstellen Sie den Stream, der in den weiteren Schritten genutzt wird.

So erstellen Sie einen Stream

1. Melden Sie sich bei der an AWS Management Console und öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com/kinesis.

2. Klicken Sie im Navigationsbereich auf Data Streams (Daten-Streams).

3. Erweitern Sie in der Navigationsleiste die Regionsauswahl und wählen Sie eine Region aus.

4. Wählen Sie Create Kinesis Stream (Kinesis-Stream erstellen).

5. Geben Sie einen Namen für Ihren Stream ein (z. B. StockTradeStream).

6. Geben Sie 1 die Anzahl der Shards ein, lassen Sie aber Estimate the number of shards you'll need (Schätzung der Anzahl der Shards, die Sie benötigen) reduziert.

7. Wählen Sie Create Kinesis Stream (Kinesis-Stream erstellen).

Auf der Seite mit der Auflistung der Kinesis Streams ist der Status Ihres Streams während des Erstellens auf CREATING gesetzt. Sobald der Stream verwendet werden kann, ändert sich der Status in ACTIVE. Wählen Sie den Namen des Streams aus. Auf der angezeigten Seite zeigt die Registerkarte Details eine Zusammenfassung Ihrer Streams-Konfiguration an. Der Abschnitt Monitoring (Überwachung) zeigt Überwachungsinformationen für den Stream an.

Zusätzliche Informationen zu Shards

Wenn Sie Kinesis Data Streams außerhalb dieses Tutorials verwenden, sollten Sie das Erstellen des Streams sorgfältiger planen. Bei der Bereitstellung von Shards sollten Sie vom höchsten erwarteten Bedarf ausgehen. In unserem Beispielszenario kommt es an der US-Börse tagsüber zu Datenverkehrsspitzen (Eastern Time). Der Bedarf sollte so geschätzt werden, dass diesen Verkehrsspitzen Rechnung getragen wird. Sie können dann entweder für den höchst möglichen Bedarf vorsorgen oder Ihren Stream an die Schwankungen anpassen.

Ein Shard ist eine Einheit für die Durchsatzkapazität. Erweitern Sie auf der Seite Kinesis Stream erstellen Schätzen Sie die Anzahl der Shards, die Sie brauchen. Geben Sie entsprechend der folgenden Informationen die durchschnittliche Datensatzgröße, die maximale Anzahl der Datensätze, die pro Sekunde geschrieben werden, und die Anzahl der Konsumentenanwendungen an:

Durchschnittliche Datensatzgröße

Eine Schätzung der berechneten durchschnittlichen Größe Ihrer Datensätze. Wenn Sie diesen Wert nicht kennen, verwenden Sie die geschätzte maximale Datensatzgröße.

Max. geschriebene Datensätze

Berücksichtigen Sie die Anzahl der Entitäten, die Daten bereitstellen, und die ungefähre Anzahl der jeweils erstellten Datensätze pro Sekunde. Beispiel: Wenn Sie Börsendaten von 20 Handelsservern erhalten und jeder pro Sekunde 250 Handelsabschlüsse generiert, beträgt die Anzahl der Handelsabschlüsse (Datensätze) 5.000/Sekunde.

Anzahl der Konsumentenanwendungen

Die Anzahl der Anwendungen, die unabhängig voneinander Daten aus dem Stream auslesen, die Stream-Daten unterschiedlich verarbeiten und unterschiedliche Ausgaben generieren. Es können mehrere Instances einer Anwendung auf verschiedenen Rechnern (d. h. in einem Cluster) ausgeführt werden, sodass ein großer Daten-Stream verarbeitet werden kann.

Wenn der gezeigte Schätzwert der Shards das aktuelle Shard-Limit übersteigt, müssen Sie ggf. eine Erhöhung des Limits beantragen, bevor Sie einen Stream mit dieser Anzahl an Shards erstellen können. Nutzen Sie zum Beantragen einer Erhöhung des Shard-Limits das Formular für Limits der Kinesis Data Streams. Weitere Informationen zu Streams und Shards finden Sie unter Kinesis-Datenstreams erstellen und verwalten.

Nächste Schritte

Erstellen Sie eine IAM Richtlinie und einen Benutzer