Unterstützung für Kinesis Video Streams API und Producer-Bibliotheken

Mit Kinesis Video Streams APIs können Sie Streams erstellen und verwalten sowie Mediendaten in und aus einem Stream lesen oder schreiben. Die Kinesis Video Streams Streams-Konsole unterstützt neben den Verwaltungsfunktionen auch Live- und video-on-demand Playback-Funktionen. Kinesis Video Streams bietet auch eine Reihe von Producer-Bibliotheken, die Sie in Ihrem Anwendungscode verwenden können, um Daten aus Ihren Medienquellen zu extrahieren und in Ihren Kinesis-Videostream hochzuladen.

Kinesis Video Streams Videostreams-API

Kinesis Video Streams ermöglicht APIs die Erstellung und Verwaltung von Kinesis Video Streams. Es ermöglicht auch APIs das Lesen und Schreiben von Mediendaten in einen Stream wie folgt:

• Producer-API — Kinesis Video Streams bietet eine PutMedia API zum Schreiben von Mediendaten in einen Kinesis-Videostream. In einer PutMedia-Anforderung sendet der Produzent einen Stream von Medienfragmenten. Ein Fragment ist eine abgeschlossene Folge von Frames. Zwischen den Frames eines Fragments und den Frames anderer Fragmente dürfen keine Abhängigkeiten bestehen. Weitere Informationen finden Sie unter PutMedia.

  Sobald Fragmente eintreffen, weist Kinesis Video Streams in aufsteigender Reihenfolge eine eindeutige Fragmentnummer zu. Es speichert auch produzenten- und serverseitige Zeitstempel für jedes Fragment als Kinesis Video Streams-spezifische Metadaten.

• Verbraucher APIs — Verbraucher können Folgendes APIs verwenden, um Daten aus einem Stream abzurufen:

  • GetMedia: Wenn Konsumenten diese API verwenden, müssen sie das Startfragment identifizieren. Die API gibt anschließend Fragmente in der Reihenfolge zurück, in der sie dem Stream hinzugefügt wurden (in aufsteigender Reihenfolge der Fragmentnummern). Die Mediendaten in den Fragmenten liegen in einem strukturierten Format wie Matroska (MKV) vor. Weitere Informationen finden Sie unter GetMedia.

    Anmerkung

    GetMedia weiß, wo sich die Fragmente befinden (archiviert im Datenspeicher oder verfügbar in Echtzeit). Wenn GetMedia beispielsweise feststellt, dass das Startfragment archiviert ist, wird das Zurückgeben von Fragmenten aus dem Datenspeicher gestartet. Wenn es neuere Fragmente zurückgeben muss, die noch nicht archiviert wurden, GetMedia wechselt es zum Lesen von Fragmenten aus einem speicherinternen Stream-Puffer.

    Dies ist ein Beispiel für einen kontinuierlichen Konsumenten, der Fragmente in der Reihenfolge verarbeitet, in der sie vom Stream übernommen werden.

    Bei Verwendung von GetMedia können Anwendungen aus- oder zurückfallen und dann ohne zusätzlichen Aufwand wieder auf den aktuellen Stand gelangen. Mit GetMedia können Anwendungen Daten verarbeiten, die im Datenspeicher archiviert sind. Sobald die Anwendung wieder auf dem aktuellen Stand ist, setzt GetMedia das Einspeisen von Mediendaten in Echtzeit unmittelbar bei deren Ankunft fort.

  • GetMediaFromFragmentList (und ListFragments): Stapelverarbeitungsanwendungen gelten als Offline-Konsumenten. Nutzer, die offline sind, können sich dafür entscheiden, bestimmte Medienfragmente oder Videobereiche explizit abzurufen, indem sie und kombinieren. ListFragments GetMediaFromFragmentList APIs ListFragmentsund GetMediaFromFragmentList ermöglichen es einer Anwendung, Videosegmente für einen bestimmten Zeitraum oder Fragmentbereich zu identifizieren und diese Fragmente dann entweder sequentiell oder parallel zur Verarbeitung abzurufen. Diese Herangehensweise eignet sich für MapReduce-Anwendungssuites, die große Datenmengen schnell parallel verarbeiten müssen.

    Nehmen wir an, dass ein Konsument die Videofragmente für einen Tag verarbeiten möchte. Der Konsument würde folgendermaßen vorgehen:

    1. Liste der Fragmente durch Aufrufen der ListFragments-API abrufen und einen Zeitraum angeben, um die gewünschten Fragmente auszuwählen.

       Die API gibt die Metadaten aller Fragmente im angegebenen Zeitraum zurück. Die Metadaten enthalten Informationen wie Fragmentnummer, produzenten- und serverseitige Zeitstempel usw.

    2. Fragment-Metadatenliste verwenden und Fragmente in beliebiger Reihenfolge abrufen. Um beispielsweise alle Fragmente für den Tag zu verarbeiten, könnte der Verbraucher die Liste in Unterlisten aufteilen und Mitarbeiter (z. B. mehrere EC2 Amazon-Instances) die Fragmente parallel mithilfe von abrufen und parallel verarbeiten lassen. GetMediaFromFragmentList

Die folgende Abbildung zeigt den Datenfluss für Fragmente und Datenblöcke im Rahmen dieser API-Aufrufe.

Wenn ein Produzent eine PutMedia-Anforderung sendet, sendet er die Medienmetadaten in der Nutzlast und dann eine Folge von Mediendatenfragmenten. Nach dem Empfang der Daten speichert Kinesis Video Streams eingehende Mediendaten als Kinesis Video Streams Streams-Chunks. Jeder Datenblock umfasst Folgendes:

• Eine Kopie der Medienmetadaten

• Ein Fragment

• Kinesis Video Streams-spezifische Metadaten, z. B. die Fragmentnummer und serverseitige und produzentenseitige Zeitstempel

Wenn ein Verbraucher Medienmetadaten anfordert, gibt Kinesis Video Streams einen Stream von Chunks zurück, beginnend mit der Fragmentnummer, die Sie in der Anfrage angeben.

Wenn Sie die Datenpersistenz für den Stream aktivieren, speichert Kinesis Video Streams nach dem Empfang eines Fragments im Stream auch eine Kopie des Fragments im Datenspeicher.

Muster für die Erkennung von Endpunkten

REST der Steuerungsebene APIs

Verwenden Sie die Kinesis Video Streams Streams-Dienstendpunkte APIs, um auf den REST der Kinesis Video Streams Streams-Kontrollebene zuzugreifen.

REST der Datenebene APIs

Kinesis Video Streams basiert auf einer Mobilfunkarchitektur, um eine bessere Skalierung und Isolierung des Datenverkehrs zu gewährleisten. Da jeder Stream einer bestimmten Zelle in einer Region zugeordnet ist, muss Ihre Anwendung die richtigen zellenspezifischen Endpunkte verwenden, denen Ihr Stream zugeordnet wurde. Wenn Sie auf die Datenebene REST zugreifen APIs, müssen Sie die richtigen Endpunkte selbst verwalten und zuordnen. Dieser Prozess, das Endpoint Discovery Pattern, wird im Folgenden beschrieben:

1. Das Endpoint Discovery Pattern beginnt mit dem Aufruf einer der GetEndpoints Aktionen. Diese Aktionen gehören zur Kontrollebene.

   1. Wenn Sie die Endpunkte für die Amazon Kinesis Video Streams — Archivierte Medien Dienste Amazon Kinesis Video Streams Streams-Medien oder abrufen, verwenden Sie. GetDataEndpoint

   2. Wenn Sie die Endpunkte fürAmazon Kinesis Kinesis-Videosignalkanäle, oder Kinesis Video Signaling abrufenAmazon Kinesis Video WebRTC-Speicher, verwenden Sie. GetSignalingChannelEndpoint

2. Zwischenspeichern Sie den Endpunkt und verwenden Sie ihn erneut.

3. Wenn der zwischengespeicherte Endpunkt nicht mehr funktioniert, rufen Sie erneut auf, um den Endpunkt GetEndpoints zu aktualisieren.

Producer-Bibliotheken

Nachdem Sie einen Kinesis-Videostream erstellt haben, können Sie damit beginnen, Daten an den Stream zu senden. In Ihrem Anwendungscode können Sie diese Bibliotheken verwenden, um Daten aus Ihren Medienquellen zu extrahieren und in Ihren Kinesis-Videostream hochzuladen. Weitere Informationen zu den verfügbaren Producer-Bibliotheken finden Sie unter Zu Kinesis Video Streams hochladen.