norbybaru / laravel-aws-timestream
Library to interact with AWS Timestream service via API
Requires
- php: ^8.0
- aws/aws-sdk-php: ^3.209
- illuminate/support: ^9.52|^10.0|^11.0
- spatie/enum: ^3.13
Requires (Dev)
- guzzlehttp/guzzle: ^7.4
- nunomaduro/larastan: ^1.0|^2.0
- orchestra/testbench: ^7.0|^8.0|^9.0
- phpunit/phpunit: ^9.5|^10.0|^11.0
- vlucas/phpdotenv: ^5.4
README
AWS Timestream is a fast, scalable, and serverless time series database service. This package is an opinionated implementation to query timestream and ingest data into timestream.
Upgrading from version 0.2.x
Please not that version 0.3.x
is still backward compatible with version 0.2.x
.
No breaking changes introduced, however i will suggest you slowly use the new Payload builder approach for Timestream ingestion as from version 0.4.x
we shall drop support for legacy builder.
See updated examples below start using new approach with TimestreamPayloadBuilder
.
Install
composer require norbybaru/laravel-aws-timestream
Configuration
- Publish config
php artisan vendor:publish --provider="NorbyBaru\AwsTimestream\TimestreamServiceProvider" --tag="timestream-config"
- Open
timestream.php
config file and setup your database name and tables - Setup you AWS Timestream keys and permissions with the following environment variable
AWS_TIMESTREAM_KEY=
AWS_TIMESTREAM_SECRET=
AWS_TIMESTREAM_PROFILE=
Basic Usage
Query Timestream
Using TimestreamBuilder::query()
will give autocomplete of all available functions
- Using
TimestreamBuilder
to build query to be passed ontoTimestreamReaderDto
which generate am object that can be consumed byTimestreamService
query function
<?php use NorbyBaru\AwsTimestream\TimestreamService; use NorbyBaru\AwsTimestream\TimestreamBuilder; use NorbyBaru\AwsTimestream\Dto\TimestreamReaderDto; public function overview(TimestreamService $timestreamService) { $queryBuilder = TimestreamBuilder::query() ->select('*') ->from("database-name", 'table-name') ->whereAgo('time', '24h', '>=') ->whereNotIn('measure_value::varchar', ['reviewer', 'open', 'closed']) ->orderBy('time', 'desc'); TimestreamReaderDto::make($queryBuilder); // response from Aws timestream return $timestreamService->query($timestreamReader) }
- Use
TimestreamReaderDto
to injectfrom
query with defaultdatabase
name and on demandtable
name. NB. No need to add->from()
query on your query builder.
<?php use NorbyBaru\AwsTimestream\TimestreamService; use NorbyBaru\AwsTimestream\TimestreamBuilder; use NorbyBaru\AwsTimestream\Dto\TimestreamReaderDto; public function overview(TimestreamService $timestreamService) { $queryBuilder = TimestreamBuilder::query() ->select('*') ->whereAgo('time', '24h', '>=') ->whereNotIn('measure_value::varchar', ['reviewer', 'open', 'closed']) ->orderBy('time', 'desc'); TimestreamReaderDto::make($queryBuilder, 'table-name'); // response from Aws timestream return $timestreamService->query($timestreamReader) }
Timestream Ingestion
We need to build our ingestion payload that Timestream will accept for ingestion.
To achieve that we can use the TimestreamPayloadBuilder
class to build a payload that Aws Timestream will understand
Example
- Build single record ingestion payload
<?php use NorbyBaru\AwsTimestream\TimestreamService; use NorbyBaru\AwsTimestream\Dto\TimestreamWriterDto; use NorbyBaru\AwsTimestream\Builder\TimestreamPayloadBuilder; public function ingest(TimestreamService $timestreamService) { $payload = TimestreamPayloadBuilder::make(measureName: 'cpu_usage') ->setMeasureValue(value: 80.5) ->setMeasureValueType(type: ValueTypeEnum::DOUBLE()) ->setDimensions(name: "mac_address", value: '00:11:22:AA:BB:CC ') ->setDimensions(name: "ref", value: 'station a') ->setTime(Carbon::now()); $timestreamWriter = TimestreamWriterDto::make($payload->toRecords())->forTable('table-name'); return $timestreamService->write($timestreamWriter); }
- Ingestion data in batch using Common Attributes to reduce ingestion cost with Timestream
<?php use NorbyBaru\AwsTimestream\TimestreamService; use NorbyBaru\AwsTimestream\Dto\TimestreamWriterDto; use NorbyBaru\AwsTimestream\Builder\TimestreamPayloadBuilder; public function ingest(TimestreamService $timestreamService) { $payloads = [ ...TimestreamPayloadBuilder::make(measureName: 'cpu_usage') ->setMeasureValue(value: 80.6) ->setDimensions(name: "ref", value: 'station a') ->toRecords(), ...TimestreamPayloadBuilder::make(measureName: 'memory_usage') ->setMeasureValue(value: 45.5) ->setDimensions(name: "ref", value: 'station b') ->toRecords(), ]; $common = CommonPayloadBuilder::make() ->setCommonDimensions(name: 'processor', value: 'unix') ->setCommonDimensions(name: 'mac_address', value: '00:11:22:AA:BB:CC') ->setCommonDimensions(name: 'device_name', value: 'device_1') ->setCommonMeasureValueType(ValueTypeEnum::DOUBLE()) ->setCommonTime(Carbon::now()) ->toArray(); $timestreamWriter = TimestreamWriterDto::make($payloads, $common, 'table-name'); return $timestreamService->write($timestreamWriter); }
Run Unit Test
composer test