Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Verwalten von Daten-Shards mit der API von Kinesis Data Streams und der AWS SDK for PHP Version 3

Mit Amazon Kinesis Data Streams können Sie Echtzeitdaten an einen Endpunkt senden. Die Rate des Datenflusses ist von der Anzahl Shards in Ihrem Stream abhängig.

Sie können 1.000 Datensätze pro Sekunde in einen einzelnen Shard schreiben. Jeder Shard verfügt außerdem über ein Upload-Limit von 1 MiB pro Sekunde. Die Nutzung wird berechnet und pro Shard abgerechnet. Mithilfe dieser Beispiele können Sie also die Datenkapazität und Kosten Ihres Streams verwalten.

In den nachstehenden Beispielen wird Folgendes veranschaulicht:

Der gesamte Beispielcode für die AWS SDK for PHP ist hier auf GitHubverfügbar.

Anmeldeinformationen

Bevor Sie den Beispielcode ausführen, konfigurieren Sie Ihre AWS Anmeldeinformationen, wie unter beschriebenAnmeldeinformationen. Importieren Sie dann die AWS SDK for PHP, wie unter beschriebenGrundlegende Verwendung.

Weitere Informationen zur Verwendung von Amazon Kinesis Data Streams finden Sie im Entwicklerhandbuch für Amazon Kinesis Data Streams.

Auflisten von Datenstrom-Shards

Listen Sie die Details von bis zu 100 Shards in einem bestimmten Stream auf.

Um die Shards in einem Kinesis-Datenstrom aufzulisten, verwenden Sie die -ListShardsOperation.

Importe

require 'vendor/autoload.php';

use Aws\Exception\AwsException;

Beispiel-Code

$kinesisClient = new Aws\Kinesis\KinesisClient([
    'profile' => 'default',
    'version' => '2013-12-02',
    'region' => 'us-east-2'
]);

$name = "my_stream_name";

try {
    $result = $kinesisClient->ListShards([
        'StreamName' => $name,
    ]);
    var_dump($result);
} catch (AwsException $e) {
    // output error message if fails
    echo $e->getMessage();
    echo "\n";
}

Weitere Datenstrom-Shards hinzufügen

Wenn Sie mehr Daten-Stream-Shards benötigen, können Sie die aktuelle Anzahl Shards erhöhen. Es wird empfohlen, bei einer Erhöhung die Shard-Anzahl zu verdoppeln. Dadurch wird eine Kopie der einzelnen Shards erstellt, die derzeit verfügbar sind, um Ihre Kapazität zu erhöhen. Sie können die Anzahl Ihrer Shards nur zweimal innerhalb von 24 Stunden verdoppeln.

Denken Sie daran, dass die Abrechnung für die Nutzung von Kinesis Data Streams pro Shard berechnet wird. Wenn die Nachfrage sinkt, empfehlen wir Ihnen, die Anzahl Ihrer Shards um die Hälfte zu reduzieren. Wenn Sie Shards entfernen, können Sie die Shard-Menge nur auf die Hälfte Ihrer aktuellen Shard-Anzahl herabsetzen.

Verwenden Sie die -UpdateShardCountOperation, um die Shard-Anzahl eines Kinesis-Datenstroms zu aktualisieren.

Importe

require 'vendor/autoload.php';

use Aws\Exception\AwsException;

Beispiel-Code

$kinesisClient = new Aws\Kinesis\KinesisClient([
    'profile' => 'default',
    'version' => '2013-12-02',
    'region' => 'us-east-2'
]);

$name = "my_stream_name";
$totalshards = 4;

try {
    $result = $kinesisClient->UpdateShardCount([
        'ScalingType' => 'UNIFORM_SCALING',
        'StreamName' => $name,
        'TargetShardCount' => $totalshards
    ]);
    var_dump($result);
} catch (AwsException $e) {
    // output error message if fails
    echo $e->getMessage();
    echo "\n";
}