rikudou / psr6-dynamo-db-bundle
PSR-6 and PSR-16 cache implementation using AWS DynamoDB for Symfony
Installs: 39 766
Dependents: 0
Suggesters: 0
Security: 0
Stars: 15
Watchers: 2
Forks: 6
Open Issues: 3
Type:symfony-bundle
Requires
- php: ^8.0
- ext-json: *
- rikudou/psr6-dynamo-db: ^3.1
- symfony/cache: ^6.0 || ^7.0
- symfony/framework-bundle: ^6.0 || ^7.0
Requires (Dev)
- friendsofphp/php-cs-fixer: ^3.0
- phpstan/phpstan: ^1.5
- phpunit/phpunit: ^9.5
README
Don't use Symfony? Use the standalone library.
Since version 2 this library uses the lightweight async-aws/dynamo-db instead of the full AWS SDK.
Installation
composer require rikudou/psr6-dynamo-db-bundle
Configuration
Create the file config/packages/dynamo_db_cache.yaml
and put at least the table name there:
rikudou_dynamo_db_cache: table: myCacheTableName
Everything else has default values, though you probably want to also configure the dynamo db client.
Configuration options:
replace_default_adapter
- set totrue
to replace the defaultAdapterInterface
andCacheInterface
implementation with the adapter from this bundle (default: false)table
- the table which will be used for storing the cache (required)client_service
- The service that will be used as DynamoDB client, if not set this bundle will try to create one (more details inclient_config
option below) but the use is limitedclient_config
- If noclient_service
is configured, it will be created from the values of this config. It contains two subkeys:region
- the AWS region (default: us-east-1)- no other options are available, if you need to configure more, please create and assign custom
client_service
encoder
- contains the settings for encoders:service
- the service which will be used as the encoder- can be one of built-in services (
rikudou.dynamo_cache.encoder.serialize
,rikudou.dynamo_cache.encoder.json
) - can be a custom service implementing the
\Rikudou\DynamoDbCache\Encoder\CacheItemEncoderInterface
interface - default value: rikudou.dynamo_cache.encoder.serialize
- can be one of built-in services (
json_options
- settings for the json encoder, ignored if another encoder is usedencode_flags
- the same flags you would pass tojson_encode()
decode_flags
- the same flags you would pass tojson_decode()
depth
- the depth argument for bothjson_encode()
andjson_decode()
primary_key_field
- the name of the field that will be used as the primary key (default: id)ttl_field
- the name of the field that will be used as the ttl field (default: ttl)value_field
- the name of the field that will be used as the value field (default: value)key_prefix
- the prefix used in front of the item keys (default: null which means none)
Autogenerated default config (via bin/console config:dump rikudou_dynamo_db_cache
):
# Default configuration for extension with alias: "rikudou_dynamo_db_cache" rikudou_dynamo_db_cache: # Replace default cache adapter with this one replace_default_adapter: false # The DynamoDB table to use as cache table: null # The service to use as the Dynamo DB client client_service: null # The Dynamo DB client configuration. If you need finer tuning, create the service yourself and assign it in client_service client_config: # The AWS region region: us-east-1 encoder: # The service to be used as the encoder/decoder service: rikudou.dynamo_cache.encoder.serialize # Settings for the json encoder json_options: # The flags that will be passed when encoding encode_flags: 0 # The flags that will be passed when decoding decode_flags: 0 # The depth of the JSON parsing for encoding/decoding depth: 512 # Session related configuration session: # The ttl for the session, defaults to ini setting session.gc_maxlifetime ttl: null # The prefix for sessions prefix: session_ # The field to be used as primary key primary_key_field: id # The field to be used as ttl ttl_field: ttl # The field to be used as value value_field: value # The prefix used in front of keys when storing key_prefix: null
Usage
You can use one of the two available services:
Rikudou\DynamoDbCache\DynamoDbCache
- this one doesn't implement the SymfonyAdapterInterface
norCacheInterface
Rikudou\DynamoDbCacheBundle\Cache\DynamoDbCacheAdapter
- this one implements the SymfonyAdapterInterface
andCacheInterface
If you set the replace_default_adapter
to true
you can also use these interfaces as services:
Symfony\Component\Cache\Adapter\AdapterInterface
- the Symfony interface for PSR-6 cacheSymfony\Contracts\Cache\CacheInterface
- the Symfony interface for simple cachePsr\Cache\CacheItemPoolInterface
- the PSR-6 interfacePsr\SimpleCache\CacheInterface
- the PSR-16 interface
Example
<?php use Rikudou\DynamoDbCacheBundle\Cache\DynamoDbCacheAdapter; use Rikudou\DynamoDbCache\DynamoDbCache; use Symfony\Contracts\Cache\ItemInterface; class MyService { public function __construct(DynamoDbCache $cache, DynamoDbCacheAdapter $adapter) { // it doesn't matter whether you use the adapter or not, the usage for PSR-6 is the same, the // only difference is that adapter implements the Symfony interface and thus you can // use it to replace the default AdapterInterface implementation $item = $cache->getItem('test'); $item2 = $adapter->getItem('test'); $item->set('some value'); $adapter->save($item); // or using the CacheInterface api $value = $adapter->get('test', function (ItemInterface $item) { $item->expiresAfter(3600); return 'new-cache-value'; }); $cache->delete('test'); } }
While using the replace_default_adapter
option:
<?php use Symfony\Component\Cache\Adapter\AdapterInterface; use Symfony\Contracts\Cache\CacheInterface; use Symfony\Contracts\Cache\ItemInterface; class MyService { public function __construct(AdapterInterface $cache) { $item = $cache->getItem('test'); // do stuff with cache item $cache->save($item); } } class MyService2 { public function __construct(CacheInterface $cache) { $cache->get('test', function (ItemInterface $item) { return 'new-value'; }); } }
Or using the PSR interfaces:
<?php use Psr\Cache\CacheItemPoolInterface; use Psr\SimpleCache\CacheInterface; class MyService { public function __construct(CacheItemPoolInterface $psr6cache, CacheInterface $psr16cache) { $item = $psr6cache->getItem('test'); $value = $item->get(); $item->set('newValue'); $item->expiresAfter(120); $psr6cache->save($item); $value = $psr16cache->get('test'); $psr16cache->set('test', 'newValue', 120); } }
Converters
This bundle supports all instances of \Psr\Cache\CacheItemInterface
with the use of converters which
convert the object to \Rikudou\DynamoDbCache\DynamoCacheItem
. Note that some information may be lost in the
conversion, notably expiration date.
This bundle has a handler for the default Symfony \Symfony\Component\Cache\CacheItem
where it retains also the
information about expiration date.
If you use any other CacheItemInterface
implementation, you may need to write your custom handler:
<?php use Rikudou\DynamoDbCache\Converter\CacheItemConverterInterface; use Psr\Cache\CacheItemInterface; use Rikudou\DynamoDbCache\DynamoCacheItem; class MyCacheItemConverter implements CacheItemConverterInterface { /** * If this methods returns true, the converter will be used */ public function supports(CacheItemInterface $cacheItem): bool { return $cacheItem instanceof MyCacheItem; } public function convert(CacheItemInterface $cacheItem): DynamoCacheItem { assert($cacheItem instanceof MyCacheItem); return new DynamoCacheItem( $cacheItem->getKey(), $cacheItem->isHit(), $cacheItem->get(), $cacheItem->getExpirationDate() // this is a custom method from the hypothetical MyCacheItem ); } }
Your converter is now automatically registered in the converter system and will be used whenever you try to save
an instance of MyCacheItem
.
If you don't use autoconfiguration, tag your service with
rikudou.dynamo_cache.converter
The default converter which will be used as last option can convert all CacheItemInterface
objects but has no
way to get the expiration date since the interface doesn't provide such information.
Session
This bundle contains a session handler to store your session data in DynamoDB.
To use it you either need to specify the handler_id
in framework.yaml
to rikudou.dynamo_cache.session
or set replace_default_adapter
to true
and remove handler_id
from framework.yaml
(the default configuration created by flex specifies null
explicitly as the handler_id
, if you want to use the
replace_default_adapter
, remove it from the config).