"""
Execution module for Amazon Elasticache using boto3.
====================================================
:depends:
- boto3 >= 1.28.0
- botocore >= 1.31.0
:configuration: This module accepts explicit elasticache credentials but can
also utilize IAM roles assigned to the instance through Instance Profiles.
Dynamic credentials are then automatically obtained from AWS API and no
further configuration is necessary. More Information available at:
.. code-block:: text
http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/iam-roles-for-amazon-ec2.html
If IAM roles are not used you need to specify them either in the minion's
config file or as a profile. For example, to specify them in the minion's
config file:
.. code-block:: yaml
elasticache.keyid: GKTADJGHEIQSXMKKRBJ08H
elasticache.key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs
A region may also be specified in the configuration:
.. code-block:: yaml
elasticache.region: us-east-1
If a region is not specified, the default is us-east-1.
It's also possible to specify key, keyid and region via a profile, either
as a passed in dict, or as a string to pull from pillars or minion config:
.. code-block:: yaml
myprofile:
keyid: GKTADJGHEIQSXMKKRBJ08H
key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs
region: us-east-1
.. versionadded:: 1.0.0
"""
# keep lint from choking on _get_conn and _cache_id
# pylint: disable=E0602
import logging
import time
from salt.exceptions import CommandExecutionError
from salt.exceptions import SaltInvocationError
from saltext.boto3.utils import boto3mod
log = logging.getLogger(__name__)
__virtualname__ = "boto3_elasticache"
try:
import botocore
# pylint: enable=unused-import
logging.getLogger("boto3").setLevel(logging.CRITICAL)
HAS_BOTO3 = True
except ImportError:
HAS_BOTO3 = False
def _get_conn(service, region=None, key=None, keyid=None, profile=None):
"""
Return a boto3 client for ``service`` using this module's dunders.
"""
return boto3mod.get_connection(
service,
opts=__opts__,
context=__context__,
region=region,
key=key,
keyid=keyid,
profile=profile,
)
[docs]
def __virtual__():
"""
Only load if boto3 is available. Minimum version is enforced via the
project's ``pyproject.toml`` dependency declaration.
"""
if HAS_BOTO3:
return __virtualname__
return (False, "The boto3_elasticache module could not be loaded: boto3 is not available.")
def __init__(opts): # pylint: disable=unused-argument
if HAS_BOTO3:
__utils__["boto3.assign_funcs"](
__name__,
"elasticache",
get_conn_funcname="_get_conn",
cache_id_funcname="_cache_id",
exactly_one_funcname=None,
)
def _collect_results(func, item, args, marker="Marker"):
ret = []
Marker = args[marker] if marker in args else ""
while Marker is not None:
r = func(**args)
ret += r.get(item)
Marker = r.get(marker)
args.update({marker: Marker})
return ret
def _describe_resource(
name=None,
name_param=None,
res_type=None,
info_node=None,
conn=None,
region=None,
key=None,
keyid=None,
profile=None,
**args,
):
if conn is None:
conn = _get_conn("elasticache", region=region, key=key, keyid=keyid, profile=profile)
try:
func = "describe_" + res_type + "s"
f = getattr(conn, func)
except (AttributeError, KeyError) as e:
raise SaltInvocationError(f"No function '{func}()' found: {e}") from e
# Undocumented, but you can't pass 'Marker' if searching for a specific resource...
args.update({name_param: name} if name else {"Marker": ""})
args = {k: v for k, v in args.items() if not k.startswith("_")}
try:
return _collect_results(f, info_node, args)
except botocore.exceptions.ClientError as e:
log.debug(e)
return None
def _delete_resource(
name,
name_param,
desc,
res_type,
wait=0,
status_param=None,
status_gone="deleted",
region=None,
key=None,
keyid=None,
profile=None,
**args,
):
"""
Delete a generic Elasticache resource.
"""
try:
wait = int(wait)
except Exception as e: # pylint: disable=broad-except
raise SaltInvocationError(
"Bad value ('{}') passed for 'wait' param - must be an " "int or boolean.".format(wait)
) from e
conn = _get_conn("elasticache", region=region, key=key, keyid=keyid, profile=profile)
if name_param in args:
log.info(
"'name: %s' param being overridden by explicitly provided '%s: %s'",
name,
name_param,
args[name_param],
)
name = args[name_param]
else:
args[name_param] = name
args = {k: v for k, v in args.items() if not k.startswith("_")}
s = None
try:
func = "delete_" + res_type
f = getattr(conn, func)
if wait:
func = "describe_" + res_type + "s"
s = globals()[func]
except (AttributeError, KeyError) as e:
raise SaltInvocationError(f"No function '{func}()' found: {e.message}") from e
try:
f(**args)
if not wait:
log.info("%s %s deletion requested.", desc.title(), name)
return True
log.info("Waiting up to %s seconds for %s %s to be deleted.", wait, desc, name)
orig_wait = wait
while wait > 0:
r = s(name=name, conn=conn)
if not r or r[0].get(status_param) == status_gone:
log.info("%s %s deleted.", desc.title(), name)
return True
sleep = wait if wait % 60 == wait else 60
log.info("Sleeping %s seconds for %s %s to be deleted.", sleep, desc, name)
time.sleep(sleep)
wait -= sleep
log.error("%s %s not deleted after %s seconds!", desc.title(), name, orig_wait)
return False
except botocore.exceptions.ClientError as e:
log.error("Failed to delete %s %s: %s", desc, name, e)
return False
def _create_resource(
name,
name_param=None,
desc=None,
res_type=None,
wait=0,
status_param=None,
status_good="available",
region=None,
key=None,
keyid=None,
profile=None,
**args,
):
try:
wait = int(wait)
except Exception as e: # pylint: disable=broad-except
raise SaltInvocationError(
"Bad value ('{}') passed for 'wait' param - must be an " "int or boolean.".format(wait)
) from e
conn = _get_conn("elasticache", region=region, key=key, keyid=keyid, profile=profile)
if name_param in args:
log.info(
"'name: %s' param being overridden by explicitly provided '%s: %s'",
name,
name_param,
args[name_param],
)
name = args[name_param]
else:
args[name_param] = name
args = {k: v for k, v in args.items() if not k.startswith("_")}
s = None
try:
func = "create_" + res_type
f = getattr(conn, func)
if wait:
func = "describe_" + res_type + "s"
s = globals()[func]
except (AttributeError, KeyError) as e:
raise SaltInvocationError(f"No function '{func}()' found: {e}") from e
try:
f(**args)
if not wait:
log.info("%s %s created.", desc.title(), name)
return True
log.info(
"Waiting up to %s seconds for %s %s to be become available.",
wait,
desc,
name,
)
orig_wait = wait
while wait > 0:
r = s(name=name, conn=conn)
if r and r[0].get(status_param) == status_good:
log.info("%s %s created and available.", desc.title(), name)
return True
sleep = wait if wait % 60 == wait else 60
log.info("Sleeping %s seconds for %s %s to become available.", sleep, desc, name)
time.sleep(sleep)
wait -= sleep
log.error("%s %s not available after %s seconds!", desc.title(), name, orig_wait)
return False
except botocore.exceptions.ClientError as e:
msg = f"Failed to create {desc} {name}: {e}"
log.error(msg)
return False
def _modify_resource(
name,
name_param=None,
desc=None,
res_type=None,
wait=0,
status_param=None,
status_good="available",
region=None,
key=None,
keyid=None,
profile=None,
**args,
):
try:
wait = int(wait)
except Exception as e: # pylint: disable=broad-except
raise SaltInvocationError(
"Bad value ('{}') passed for 'wait' param - must be an " "int or boolean.".format(wait)
) from e
conn = _get_conn("elasticache", region=region, key=key, keyid=keyid, profile=profile)
if name_param in args:
log.info(
"'name: %s' param being overridden by explicitly provided '%s: %s'",
name,
name_param,
args[name_param],
)
name = args[name_param]
else:
args[name_param] = name
args = {k: v for k, v in args.items() if not k.startswith("_")}
s = None
try:
func = "modify_" + res_type
f = getattr(conn, func)
if wait:
func = "describe_" + res_type + "s"
s = globals()[func]
except (AttributeError, KeyError) as e:
raise SaltInvocationError(f"No function '{func}()' found: {e}") from e
try:
f(**args)
if not wait:
log.info("%s %s modification requested.", desc.title(), name)
return True
log.info(
"Waiting up to %s seconds for %s %s to be become available.",
wait,
desc,
name,
)
orig_wait = wait
while wait > 0:
r = s(name=name, conn=conn)
if r and r[0].get(status_param) == status_good:
log.info("%s %s modified and available.", desc.title(), name)
return True
sleep = wait if wait % 60 == wait else 60
log.info("Sleeping %s seconds for %s %s to become available.", sleep, desc, name)
time.sleep(sleep)
wait -= sleep
log.error("%s %s not available after %s seconds!", desc.title(), name, orig_wait)
return False
except botocore.exceptions.ClientError as e:
msg = f"Failed to modify {desc} {name}: {e}"
log.error(msg)
return False
[docs]
def describe_cache_clusters(
name=None, conn=None, region=None, key=None, keyid=None, profile=None, **args
):
"""
Return details about all (or just one) Elasticache cache clusters.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.describe_cache_clusters
salt myminion boto3_elasticache.describe_cache_clusters myelasticache
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.describe_cache_clusters
"""
return _describe_resource(
name=name,
name_param="CacheClusterId",
res_type="cache_cluster",
info_node="CacheClusters",
conn=conn,
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def cache_cluster_exists(name, conn=None, region=None, key=None, keyid=None, profile=None):
"""
Check to see if a cache cluster exists.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.cache_cluster_exists myelasticache
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.cache_cluster_exists
"""
return bool(
describe_cache_clusters(
name=name, conn=conn, region=region, key=key, keyid=keyid, profile=profile
)
)
[docs]
def create_cache_cluster(
name,
wait=600,
security_groups=None,
region=None,
key=None,
keyid=None,
profile=None,
**args,
):
"""
Create a cache cluster.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.create_cache_cluster name=myCacheCluster \
Engine=redis \
CacheNodeType=cache.t2.micro \
NumCacheNodes=1 \
SecurityGroupIds='[sg-11223344]' \
CacheSubnetGroupName=myCacheSubnetGroup
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.create_cache_cluster
"""
if security_groups:
if not isinstance(security_groups, list):
security_groups = [security_groups]
sgs = __salt__["boto3_secgroup.convert_to_group_ids"](
groups=security_groups, region=region, key=key, keyid=keyid, profile=profile
)
if "SecurityGroupIds" not in args:
args["SecurityGroupIds"] = []
args["SecurityGroupIds"] += sgs
args = {k: v for k, v in args.items() if not k.startswith("_")}
return _create_resource(
name,
name_param="CacheClusterId",
desc="cache cluster",
res_type="cache_cluster",
wait=wait,
status_param="CacheClusterStatus",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def modify_cache_cluster(
name,
wait=600,
security_groups=None,
region=None,
key=None,
keyid=None,
profile=None,
**args,
):
"""
Update a cache cluster in place.
Notes: {ApplyImmediately: False} is pretty danged silly in the context of salt.
You can pass it, but for fairly obvious reasons the results over multiple
runs will be undefined and probably contrary to your desired state.
Reducing the number of nodes requires an EXPLICIT CacheNodeIdsToRemove be
passed, which until a reasonable heuristic for programmatically deciding
which nodes to remove has been established, MUST be decided and populated
intentionally before a state call, and removed again before the next. In
practice this is not particularly useful and should probably be avoided.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.create_cache_cluster name=myCacheCluster \
NotificationTopicStatus=inactive
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.modify_cache_cluster
"""
if security_groups:
if not isinstance(security_groups, list):
security_groups = [security_groups]
sgs = __salt__["boto3_secgroup.convert_to_group_ids"](
groups=security_groups, region=region, key=key, keyid=keyid, profile=profile
)
if "SecurityGroupIds" not in args:
args["SecurityGroupIds"] = []
args["SecurityGroupIds"] += sgs
args = {k: v for k, v in args.items() if not k.startswith("_")}
return _modify_resource(
name,
name_param="CacheClusterId",
desc="cache cluster",
res_type="cache_cluster",
wait=wait,
status_param="CacheClusterStatus",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def delete_cache_cluster(name, wait=600, region=None, key=None, keyid=None, profile=None, **args):
"""
Delete a cache cluster.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.delete myelasticache
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.delete_cache_cluster
"""
return _delete_resource(
name,
name_param="CacheClusterId",
desc="cache cluster",
res_type="cache_cluster",
wait=wait,
status_param="CacheClusterStatus",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def describe_replication_groups(
name=None, conn=None, region=None, key=None, keyid=None, profile=None
):
"""
Return details about all (or just one) Elasticache replication groups.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.describe_replication_groups
salt myminion boto3_elasticache.describe_replication_groups myelasticache
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.describe_replication_groups
"""
return _describe_resource(
name=name,
name_param="ReplicationGroupId",
res_type="replication_group",
info_node="ReplicationGroups",
conn=conn,
region=region,
key=key,
keyid=keyid,
profile=profile,
)
[docs]
def replication_group_exists(name, region=None, key=None, keyid=None, profile=None):
"""
Check to see if a replication group exists.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.replication_group_exists myelasticache
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.replication_group_exists
"""
return bool(
describe_replication_groups(name=name, region=region, key=key, keyid=keyid, profile=profile)
)
[docs]
def create_replication_group(
name,
wait=600,
security_groups=None,
region=None,
key=None,
keyid=None,
profile=None,
**args,
):
"""
Create a replication group.
Params are extensive and variable - see
http://boto3.readthedocs.io/en/latest/reference/services/elasticache.html?#ElastiCache.Client.create_replication_group
for in-depth usage documentation.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.create_replication_group \
name=myelasticache \
ReplicationGroupDescription=description
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.create_replication_group
"""
if security_groups:
if not isinstance(security_groups, list):
security_groups = [security_groups]
sgs = __salt__["boto3_secgroup.convert_to_group_ids"](
groups=security_groups, region=region, key=key, keyid=keyid, profile=profile
)
if "SecurityGroupIds" not in args:
args["SecurityGroupIds"] = []
args["SecurityGroupIds"] += sgs
args = {k: v for k, v in args.items() if not k.startswith("_")}
return _create_resource(
name,
name_param="ReplicationGroupId",
desc="replication group",
res_type="replication_group",
wait=wait,
status_param="Status",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def modify_replication_group(
name,
wait=600,
security_groups=None,
region=None,
key=None,
keyid=None,
profile=None,
**args,
):
"""
Modify a replication group.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.modify_replication_group \
name=myelasticache \
ReplicationGroupDescription=newDescription
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.modify_replication_group
"""
if security_groups:
if not isinstance(security_groups, list):
security_groups = [security_groups]
sgs = __salt__["boto3_secgroup.convert_to_group_ids"](
groups=security_groups, region=region, key=key, keyid=keyid, profile=profile
)
if "SecurityGroupIds" not in args:
args["SecurityGroupIds"] = []
args["SecurityGroupIds"] += sgs
args = {k: v for k, v in args.items() if not k.startswith("_")}
return _modify_resource(
name,
name_param="ReplicationGroupId",
desc="replication group",
res_type="replication_group",
wait=wait,
status_param="Status",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def delete_replication_group(
name, wait=600, region=None, key=None, keyid=None, profile=None, **args
):
"""
Delete an ElastiCache replication group, optionally taking a snapshot first.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.delete_replication_group my-replication-group
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.delete_replication_group
"""
return _delete_resource(
name,
name_param="ReplicationGroupId",
desc="replication group",
res_type="replication_group",
wait=wait,
status_param="Status",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def describe_cache_subnet_groups(
name=None, conn=None, region=None, key=None, keyid=None, profile=None
):
"""
Return details about all (or just one) Elasticache replication groups.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.describe_cache_subnet_groups region=us-east-1
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.describe_cache_subnet_groups
"""
return _describe_resource(
name=name,
name_param="CacheSubnetGroupName",
res_type="cache_subnet_group",
info_node="CacheSubnetGroups",
conn=conn,
region=region,
key=key,
keyid=keyid,
profile=profile,
)
[docs]
def cache_subnet_group_exists(name, region=None, key=None, keyid=None, profile=None):
"""
Check to see if an ElastiCache subnet group exists.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.cache_subnet_group_exists my-subnet-group
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.cache_subnet_group_exists
"""
return bool(
describe_cache_subnet_groups(
name=name, region=region, key=key, keyid=keyid, profile=profile
)
)
[docs]
def list_cache_subnet_groups(region=None, key=None, keyid=None, profile=None):
"""
Return a list of all cache subnet group names
Example:
.. code-block:: bash
salt myminion boto3_elasticache.list_cache_subnet_groups region=us-east-1
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.list_cache_subnet_groups
"""
return [
g["CacheSubnetGroupName"]
for g in describe_cache_subnet_groups(None, region, key, keyid, profile)
]
[docs]
def create_cache_subnet_group(
name, subnets=None, region=None, key=None, keyid=None, profile=None, **args
):
"""
Create an ElastiCache subnet group
Example:
.. code-block:: bash
salt myminion boto3_elasticache.create_cache_subnet_group name=my-subnet-group \
CacheSubnetGroupDescription="description" \
subnets='[myVPCSubnet1,myVPCSubnet2]'
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.create_cache_subnet_group
"""
if subnets:
if "SubnetIds" not in args:
args["SubnetIds"] = []
if not isinstance(subnets, list):
subnets = [subnets]
for subnet in subnets:
if subnet.startswith("subnet-"):
# Moderately safe assumption... :) Will be caught further down if incorrect.
args["SubnetIds"] += [subnet]
continue
sn = __salt__["boto3_vpc.describe_subnets"](
subnet_names=subnet,
region=region,
key=key,
keyid=keyid,
profile=profile,
).get("subnets")
if not sn:
raise SaltInvocationError(f"Could not resolve Subnet Name {subnet} to an ID.")
if len(sn) == 1:
args["SubnetIds"] += [sn[0]["id"]]
elif len(sn) > 1:
raise CommandExecutionError(f"Subnet Name {subnet} returned more than one ID.")
args = {k: v for k, v in args.items() if not k.startswith("_")}
return _create_resource(
name,
name_param="CacheSubnetGroupName",
desc="cache subnet group",
res_type="cache_subnet_group",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def modify_cache_subnet_group(
name, subnets=None, region=None, key=None, keyid=None, profile=None, **args
):
"""
Modify an ElastiCache subnet group
Example:
.. code-block:: bash
salt myminion boto3_elasticache.modify_cache_subnet_group \
name=my-subnet-group \
subnets='[myVPCSubnet3]'
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.modify_cache_subnet_group
"""
if subnets:
if "SubnetIds" not in args:
args["SubnetIds"] = []
if not isinstance(subnets, list):
subnets = [subnets]
for subnet in subnets:
sn = __salt__["boto3_vpc.describe_subnets"](
subnet_names=subnet,
region=region,
key=key,
keyid=keyid,
profile=profile,
).get("subnets")
if len(sn) == 1:
args["SubnetIds"] += [sn[0]["id"]]
elif len(sn) > 1:
raise CommandExecutionError(f"Subnet Name {subnet} returned more than one ID.")
elif subnet.startswith("subnet-"):
# Moderately safe assumption... :) Will be caught later if incorrect.
args["SubnetIds"] += [subnet]
else:
raise SaltInvocationError(f"Could not resolve Subnet Name {subnet} to an ID.")
args = {k: v for k, v in args.items() if not k.startswith("_")}
return _modify_resource(
name,
name_param="CacheSubnetGroupName",
desc="cache subnet group",
res_type="cache_subnet_group",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def delete_cache_subnet_group(name, region=None, key=None, keyid=None, profile=None, **args):
"""
Delete an ElastiCache subnet group.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.delete_subnet_group my-subnet-group region=us-east-1
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.delete_cache_subnet_group
"""
return _delete_resource(
name,
name_param="CacheSubnetGroupName",
desc="cache subnet group",
res_type="cache_subnet_group",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def describe_cache_security_groups(
name=None, conn=None, region=None, key=None, keyid=None, profile=None
):
"""
Return details about all (or just one) Elasticache cache clusters.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.describe_cache_security_groups
salt myminion boto3_elasticache.describe_cache_security_groups mycachesecgrp
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.describe_cache_security_groups
"""
return _describe_resource(
name=name,
name_param="CacheSecurityGroupName",
res_type="cache_security_group",
info_node="CacheSecurityGroups",
conn=conn,
region=region,
key=key,
keyid=keyid,
profile=profile,
)
[docs]
def cache_security_group_exists(name, region=None, key=None, keyid=None, profile=None):
"""
Check to see if an ElastiCache security group exists.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.cache_security_group_exists mysecuritygroup
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.cache_security_group_exists
"""
return bool(
describe_cache_security_groups(
name=name, region=region, key=key, keyid=keyid, profile=profile
)
)
[docs]
def create_cache_security_group(name, region=None, key=None, keyid=None, profile=None, **args):
"""
Create a cache security group.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.create_cache_security_group mycachesecgrp Description='My Cache Security Group'
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.create_cache_security_group
"""
return _create_resource(
name,
name_param="CacheSecurityGroupName",
desc="cache security group",
res_type="cache_security_group",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def delete_cache_security_group(name, region=None, key=None, keyid=None, profile=None, **args):
"""
Delete a cache security group.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.delete_cache_security_group myelasticachesg
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.delete_cache_security_group
"""
return _delete_resource(
name,
name_param="CacheSecurityGroupName",
desc="cache security group",
res_type="cache_security_group",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def authorize_cache_security_group_ingress(
name, region=None, key=None, keyid=None, profile=None, **args
):
"""
Authorize network ingress from an ec2 security group to a cache security group.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.authorize_cache_security_group_ingress \
mycachesecgrp \
EC2SecurityGroupName=someEC2sg \
EC2SecurityGroupOwnerId=SOMEOWNERID
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.authorize_cache_security_group_ingress
"""
conn = _get_conn("elasticache", region=region, key=key, keyid=keyid, profile=profile)
if "CacheSecurityGroupName" in args:
log.info(
"'name: %s' param being overridden by explicitly provided "
"'CacheSecurityGroupName: %s'",
name,
args["CacheSecurityGroupName"],
)
name = args["CacheSecurityGroupName"]
else:
args["CacheSubnetGroupName"] = name
args = {k: v for k, v in args.items() if not k.startswith("_")}
try:
conn.authorize_cache_security_group_ingress(**args)
log.info(
"Authorized %s to cache security group %s.",
args["EC2SecurityGroupName"],
name,
)
return True
except botocore.exceptions.ClientError as e:
log.error("Failed to update security group %s: %s", name, e)
return False
[docs]
def revoke_cache_security_group_ingress(
name, region=None, key=None, keyid=None, profile=None, **args
):
"""
Revoke network ingress from an ec2 security group to a cache security
group.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.revoke_cache_security_group_ingress \
mycachesecgrp \
EC2SecurityGroupName=someEC2sg \
EC2SecurityGroupOwnerId=SOMEOWNERID
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.revoke_cache_security_group_ingress
"""
conn = _get_conn("elasticache", region=region, key=key, keyid=keyid, profile=profile)
if "CacheSecurityGroupName" in args:
log.info(
"'name: %s' param being overridden by explicitly provided "
"'CacheSecurityGroupName: %s'",
name,
args["CacheSecurityGroupName"],
)
name = args["CacheSecurityGroupName"]
else:
args["CacheSubnetGroupName"] = name
args = {k: v for k, v in args.items() if not k.startswith("_")}
try:
conn.revoke_cache_security_group_ingress(**args)
log.info(
"Revoked %s from cache security group %s.",
args["EC2SecurityGroupName"],
name,
)
return True
except botocore.exceptions.ClientError as e:
log.error("Failed to update security group %s: %s", name, e)
return False
[docs]
def copy_snapshot(name, region=None, key=None, keyid=None, profile=None, **args):
"""
Make a copy of an existing snapshot.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.copy_snapshot name=mySnapshot \
TargetSnapshotName=copyOfMySnapshot
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.copy_snapshot
"""
conn = _get_conn("elasticache", region=region, key=key, keyid=keyid, profile=profile)
if "SourceSnapshotName" in args:
log.info(
"'name: %s' param being overridden by explicitly provided 'SourceSnapshotName: %s'",
name,
args["SourceSnapshotName"],
)
name = args["SourceSnapshotName"]
else:
args["SourceSnapshotName"] = name
args = {k: v for k, v in args.items() if not k.startswith("_")}
try:
conn.copy_snapshot(**args)
log.info("Snapshot %s copied to %s.", name, args["TargetSnapshotName"])
return True
except botocore.exceptions.ClientError as e:
log.error("Failed to copy snapshot %s: %s", name, e)
return False
[docs]
def describe_cache_parameter_groups(
name=None, conn=None, region=None, key=None, keyid=None, profile=None
):
"""
Return details about all (or just one) Elasticache cache clusters.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.describe_cache_parameter_groups
salt myminion boto3_elasticache.describe_cache_parameter_groups myParameterGroup
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.describe_cache_parameter_groups
"""
return _describe_resource(
name=name,
name_param="CacheParameterGroupName",
res_type="cache_parameter_group",
info_node="CacheParameterGroups",
conn=conn,
region=region,
key=key,
keyid=keyid,
profile=profile,
)
[docs]
def create_cache_parameter_group(name, region=None, key=None, keyid=None, profile=None, **args):
"""
Create a cache parameter group.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.create_cache_parameter_group \
name=myParamGroup \
CacheParameterGroupFamily=redis2.8 \
Description="My Parameter Group"
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.create_cache_parameter_group
"""
return _create_resource(
name,
name_param="CacheParameterGroupName",
desc="cache parameter group",
res_type="cache_parameter_group",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)
[docs]
def delete_cache_parameter_group(name, region=None, key=None, keyid=None, profile=None, **args):
"""
Delete a cache parameter group.
Example:
.. code-block:: bash
salt myminion boto3_elasticache.delete_cache_parameter_group myParamGroup
CLI Example:
.. code-block:: bash
salt-call boto3_elasticache.delete_cache_parameter_group
"""
return _delete_resource(
name,
name_param="CacheParameterGroupName",
desc="cache parameter group",
res_type="cache_parameter_group",
region=region,
key=key,
keyid=keyid,
profile=profile,
**args,
)