Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Administrar fragmentos de datos mediante la API de flujos de datos de Kinesis y la versión 3 de AWS SDK para PHP

Amazon Kinesis Data Streams le permite enviar datos en tiempo real a un punto de enlace. La velocidad del flujo de datos depende del número de fragmentos de la secuencia.

Puede escribir 1000 registros por segundo en un único fragmento. Cada fragmento también tiene un límite de carga de 1 MiB por segundo. El uso se calcula y se cobra por fragmento, así que debe usar estos ejemplos para administrar la capacidad de los datos y el costo de la secuencia.

Los siguientes ejemplos muestran cómo:

Todo el código de ejemplo de AWS SDK para PHP está disponible aquí en GitHub.

Credenciales

Antes de ejecutar el código de ejemplo, configure sus credenciales de AWS, como se indica en Autenticación AWS con la AWS SDK para PHP versión 3. A continuación, importe AWS SDK para PHP, como se indica en Instalación del AWS SDK para PHP versión 3.

Para obtener más información sobre el uso de Amazon Kinesis Data Streams, consulte la guía para desarrolladores Amazon Kinesis Data Streams.

Lista de fragmentos de secuencias de datos

Enumere los detalles de hasta 100 fragmentos de una secuencia específica.

Para enumerar los fragmentos de un flujo de datos de Kinesis, utilice la operación ListShards.

Importaciones

require 'vendor/autoload.php';

use Aws\Exception\AwsException;

Código de muestra

$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";
}

Añadir más fragmentos de secuencias de datos

Si necesita más fragmentos de secuencias de datos, puede aumentar su número actual de fragmentos. Le recomendamos que duplique el recuento de fragmentos cuando aumente. Esto crea una copia de cada partición disponible actualmente para aumentar la capacidad. Puede duplicar el número de los fragmentos solo dos veces en un periodo de 24 horas.

Recuerde que la facturación por el uso de Kinesis Data Streams se calcula por fragmento, de manera que cuando la demanda disminuye, le recomendamos que reduzca el número de fragmentos a la mitad. Al eliminar los fragmentos, solo puede reducir la cantidad de fragmentos a la mitad de su recuento de fragmentos actual.

Para actualizar el recuento de fragmentos de un flujo de datos de Kinesis, utilice la operación UpdateShardCount.

Importaciones

require 'vendor/autoload.php';

use Aws\Exception\AwsException;

Código de muestra

$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";
}