AWS SDK for PHP 3.xでAmazon KinesisのPUT/GETを試す小さなサンプル

前提

• リージョン：東京
• AWS SDK for PHP 3.xがインストール済であること
• credencialまたはIAMロールが登録済であること
• ストリーム(test)が作成済みであること

サンプル

put.php

<?php
require './vendor/autoload.php';

$client = new Aws\Kinesis\KinesisClient([
        'version' => 'latest',
        'region' => 'ap-northeast-1'
]);

$result = $client->putRecords([
        'Records' => [
                [
                        'Data' => 'hogehoge',
                        'PartitionKey' => 'hoge',
                ],
        ],
        'StreamName' => 'test',
]);
var_dump($result);

get.php

<?php
require './vendor/autoload.php';

$client = new Aws\Kinesis\KinesisClient([
        'version' => 'latest',
        'region' => 'ap-northeast-1'
]);

$sharedIDResult = $client->getShardIterator([
        'ShardId' => 'shardId-000000000000',
      'ShardIteratorType' => 'TRIM_HORIZON',
//        'ShardIteratorType' => 'AFTER_SEQUENCE_NUMBER',
        'StreamName' => 'test',
//        'StartingSequenceNumber' => 'xxxx'
]);

$ite = $sharedIDResult['ShardIterator'];

$result = $client->getRecords([
       'ShardIterator' => $ite,
]);
var_dump($result);