Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(134)

Unified Diff: third_party/gsutil/20110627/boto/boto/rds/__init__.py

Issue 10199002: Upgrade gsutil to 3.4 (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Addressed comments Created 8 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: third_party/gsutil/20110627/boto/boto/rds/__init__.py
diff --git a/third_party/gsutil/20110627/boto/boto/rds/__init__.py b/third_party/gsutil/20110627/boto/boto/rds/__init__.py
deleted file mode 100644
index 9acf1038cbc25633c5b95fa2e9ece33738092ea4..0000000000000000000000000000000000000000
--- a/third_party/gsutil/20110627/boto/boto/rds/__init__.py
+++ /dev/null
@@ -1,974 +0,0 @@
-# Copyright (c) 2009 Mitch Garnaat http://garnaat.org/
-#
-# Permission is hereby granted, free of charge, to any person obtaining a
-# copy of this software and associated documentation files (the
-# "Software"), to deal in the Software without restriction, including
-# without limitation the rights to use, copy, modify, merge, publish, dis-
-# tribute, sublicense, and/or sell copies of the Software, and to permit
-# persons to whom the Software is furnished to do so, subject to the fol-
-# lowing conditions:
-#
-# The above copyright notice and this permission notice shall be included
-# in all copies or substantial portions of the Software.
-#
-# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
-# OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABIL-
-# ITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT
-# SHALL THE AUTHOR BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
-# WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
-# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
-# IN THE SOFTWARE.
-#
-
-import boto.utils
-import urllib
-from boto.connection import AWSQueryConnection
-from boto.rds.dbinstance import DBInstance
-from boto.rds.dbsecuritygroup import DBSecurityGroup
-from boto.rds.parametergroup import ParameterGroup
-from boto.rds.dbsnapshot import DBSnapshot
-from boto.rds.event import Event
-from boto.rds.regioninfo import RDSRegionInfo
-
-def regions():
- """
- Get all available regions for the RDS service.
-
- :rtype: list
- :return: A list of :class:`boto.rds.regioninfo.RDSRegionInfo`
- """
- return [RDSRegionInfo(name='us-east-1',
- endpoint='rds.amazonaws.com'),
- RDSRegionInfo(name='eu-west-1',
- endpoint='eu-west-1.rds.amazonaws.com'),
- RDSRegionInfo(name='us-west-1',
- endpoint='us-west-1.rds.amazonaws.com'),
- RDSRegionInfo(name='ap-northeast-1',
- endpoint='ap-northeast-1.rds.amazonaws.com'),
- RDSRegionInfo(name='ap-southeast-1',
- endpoint='ap-southeast-1.rds.amazonaws.com')
- ]
-
-def connect_to_region(region_name):
- for region in regions():
- if region.name == region_name:
- return region.connect()
- return None
-
-#boto.set_stream_logger('rds')
-
-class RDSConnection(AWSQueryConnection):
-
- DefaultRegionName = 'us-east-1'
- DefaultRegionEndpoint = 'rds.amazonaws.com'
- APIVersion = '2009-10-16'
-
- def __init__(self, aws_access_key_id=None, aws_secret_access_key=None,
- is_secure=True, port=None, proxy=None, proxy_port=None,
- proxy_user=None, proxy_pass=None, debug=0,
- https_connection_factory=None, region=None, path='/'):
- if not region:
- region = RDSRegionInfo(self, self.DefaultRegionName,
- self.DefaultRegionEndpoint)
- self.region = region
- AWSQueryConnection.__init__(self, aws_access_key_id, aws_secret_access_key,
- is_secure, port, proxy, proxy_port, proxy_user,
- proxy_pass, self.region.endpoint, debug,
- https_connection_factory, path)
-
- def _required_auth_capability(self):
- return ['rds']
-
- # DB Instance methods
-
- def get_all_dbinstances(self, instance_id=None, max_records=None,
- marker=None):
- """
- Retrieve all the DBInstances in your account.
-
- :type instance_id: str
- :param instance_id: DB Instance identifier. If supplied, only information
- this instance will be returned. Otherwise, info
- about all DB Instances will be returned.
-
- :type max_records: int
- :param max_records: The maximum number of records to be returned.
- If more results are available, a MoreToken will
- be returned in the response that can be used to
- retrieve additional records. Default is 100.
-
- :type marker: str
- :param marker: The marker provided by a previous request.
-
- :rtype: list
- :return: A list of :class:`boto.rds.dbinstance.DBInstance`
- """
- params = {}
- if instance_id:
- params['DBInstanceIdentifier'] = instance_id
- if max_records:
- params['MaxRecords'] = max_records
- if marker:
- params['Marker'] = marker
- return self.get_list('DescribeDBInstances', params, [('DBInstance', DBInstance)])
-
- def create_dbinstance(self, id, allocated_storage, instance_class,
- master_username, master_password, port=3306,
- engine='MySQL5.1', db_name=None, param_group=None,
- security_groups=None, availability_zone=None,
- preferred_maintenance_window=None,
- backup_retention_period=None,
- preferred_backup_window=None,
- multi_az=False,
- engine_version=None,
- auto_minor_version_upgrade=True):
- """
- Create a new DBInstance.
-
- :type id: str
- :param id: Unique identifier for the new instance.
- Must contain 1-63 alphanumeric characters.
- First character must be a letter.
- May not end with a hyphen or contain two consecutive hyphens
-
- :type allocated_storage: int
- :param allocated_storage: Initially allocated storage size, in GBs.
- Valid values are [5-1024]
-
- :type instance_class: str
- :param instance_class: The compute and memory capacity of the DBInstance.
-
- Valid values are:
-
- * db.m1.small
- * db.m1.large
- * db.m1.xlarge
- * db.m2.xlarge
- * db.m2.2xlarge
- * db.m2.4xlarge
-
- :type engine: str
- :param engine: Name of database engine. Must be MySQL5.1 for now.
-
- :type master_username: str
- :param master_username: Name of master user for the DBInstance.
- Must be 1-15 alphanumeric characters, first
- must be a letter.
-
- :type master_password: str
- :param master_password: Password of master user for the DBInstance.
- Must be 4-16 alphanumeric characters.
-
- :type port: int
- :param port: Port number on which database accepts connections.
- Valid values [1115-65535]. Defaults to 3306.
-
- :type db_name: str
- :param db_name: Name of a database to create when the DBInstance
- is created. Default is to create no databases.
-
- :type param_group: str
- :param param_group: Name of DBParameterGroup to associate with
- this DBInstance. If no groups are specified
- no parameter groups will be used.
-
- :type security_groups: list of str or list of DBSecurityGroup objects
- :param security_groups: List of names of DBSecurityGroup to authorize on
- this DBInstance.
-
- :type availability_zone: str
- :param availability_zone: Name of the availability zone to place
- DBInstance into.
-
- :type preferred_maintenance_window: str
- :param preferred_maintenance_window: The weekly time range (in UTC)
- during which maintenance can occur.
- Default is Sun:05:00-Sun:09:00
-
- :type backup_retention_period: int
- :param backup_retention_period: The number of days for which automated
- backups are retained. Setting this to
- zero disables automated backups.
-
- :type preferred_backup_window: str
- :param preferred_backup_window: The daily time range during which
- automated backups are created (if
- enabled). Must be in h24:mi-hh24:mi
- format (UTC).
-
- :type multi_az: bool
- :param multi_az: If True, specifies the DB Instance will be
- deployed in multiple availability zones.
-
- :type engine_version: str
- :param engine_version: Version number of the database engine to use.
-
- :type auto_minor_version_upgrade: bool
- :param auto_minor_version_upgrade: Indicates that minor engine
- upgrades will be applied
- automatically to the Read Replica
- during the maintenance window.
- Default is True.
-
- :rtype: :class:`boto.rds.dbinstance.DBInstance`
- :return: The new db instance.
- """
- params = {'DBInstanceIdentifier' : id,
- 'AllocatedStorage' : allocated_storage,
- 'DBInstanceClass' : instance_class,
- 'Engine' : engine,
- 'MasterUsername' : master_username,
- 'MasterUserPassword' : master_password}
- if port:
- params['Port'] = port
- if db_name:
- params['DBName'] = db_name
- if param_group:
- params['DBParameterGroupName'] = param_group
- if security_groups:
- l = []
- for group in security_groups:
- if isinstance(group, DBSecurityGroup):
- l.append(group.name)
- else:
- l.append(group)
- self.build_list_params(params, l, 'DBSecurityGroups.member')
- if availability_zone:
- params['AvailabilityZone'] = availability_zone
- if preferred_maintenance_window:
- params['PreferredMaintenanceWindow'] = preferred_maintenance_window
- if backup_retention_period:
- params['BackupRetentionPeriod'] = backup_retention_period
- if preferred_backup_window:
- params['PreferredBackupWindow'] = preferred_backup_window
- if multi_az:
- params['MultiAZ'] = 'true'
- if engine_version:
- params['EngineVersion'] = engine_version
- if auto_minor_version_upgrade is False:
- params['AutoMinorVersionUpgrade'] = 'false'
-
- return self.get_object('CreateDBInstance', params, DBInstance)
-
- def create_dbinstance_read_replica(self, id, source_id,
- instance_class=None,
- port=3306,
- availability_zone=None,
- auto_minor_version_upgrade=None):
- """
- Create a new DBInstance Read Replica.
-
- :type id: str
- :param id: Unique identifier for the new instance.
- Must contain 1-63 alphanumeric characters.
- First character must be a letter.
- May not end with a hyphen or contain two consecutive hyphens
-
- :type source_id: str
- :param source_id: Unique identifier for the DB Instance for which this
- DB Instance will act as a Read Replica.
-
- :type instance_class: str
- :param instance_class: The compute and memory capacity of the
- DBInstance. Default is to inherit from
- the source DB Instance.
-
- Valid values are:
-
- * db.m1.small
- * db.m1.large
- * db.m1.xlarge
- * db.m2.xlarge
- * db.m2.2xlarge
- * db.m2.4xlarge
-
- :type port: int
- :param port: Port number on which database accepts connections.
- Default is to inherit from source DB Instance.
- Valid values [1115-65535]. Defaults to 3306.
-
- :type availability_zone: str
- :param availability_zone: Name of the availability zone to place
- DBInstance into.
-
- :type auto_minor_version_upgrade: bool
- :param auto_minor_version_upgrade: Indicates that minor engine
- upgrades will be applied
- automatically to the Read Replica
- during the maintenance window.
- Default is to inherit this value
- from the source DB Instance.
-
- :rtype: :class:`boto.rds.dbinstance.DBInstance`
- :return: The new db instance.
- """
- params = {'DBInstanceIdentifier' : id,
- 'SourceDBInstanceIdentifier' : source_id}
- if instance_class:
- params['DBInstanceClass'] = instance_class
- if port:
- params['Port'] = port
- if availability_zone:
- params['AvailabilityZone'] = availability_zone
- if auto_minor_version_upgrade is not None:
- if auto_minor_version_upgrade is True:
- params['AutoMinorVersionUpgrade'] = 'true'
- else:
- params['AutoMinorVersionUpgrade'] = 'false'
-
- return self.get_object('CreateDBInstanceReadReplica',
- params, DBInstance)
-
- def modify_dbinstance(self, id, param_group=None, security_groups=None,
- preferred_maintenance_window=None,
- master_password=None, allocated_storage=None,
- instance_class=None,
- backup_retention_period=None,
- preferred_backup_window=None,
- multi_az=False,
- apply_immediately=False):
- """
- Modify an existing DBInstance.
-
- :type id: str
- :param id: Unique identifier for the new instance.
-
- :type security_groups: list of str or list of DBSecurityGroup objects
- :param security_groups: List of names of DBSecurityGroup to authorize on
- this DBInstance.
-
- :type preferred_maintenance_window: str
- :param preferred_maintenance_window: The weekly time range (in UTC)
- during which maintenance can
- occur.
- Default is Sun:05:00-Sun:09:00
-
- :type master_password: str
- :param master_password: Password of master user for the DBInstance.
- Must be 4-15 alphanumeric characters.
-
- :type allocated_storage: int
- :param allocated_storage: The new allocated storage size, in GBs.
- Valid values are [5-1024]
-
- :type instance_class: str
- :param instance_class: The compute and memory capacity of the
- DBInstance. Changes will be applied at
- next maintenance window unless
- apply_immediately is True.
-
- Valid values are:
-
- * db.m1.small
- * db.m1.large
- * db.m1.xlarge
- * db.m2.xlarge
- * db.m2.2xlarge
- * db.m2.4xlarge
-
- :type apply_immediately: bool
- :param apply_immediately: If true, the modifications will be applied
- as soon as possible rather than waiting for
- the next preferred maintenance window.
-
- :type backup_retention_period: int
- :param backup_retention_period: The number of days for which automated
- backups are retained. Setting this to
- zero disables automated backups.
-
- :type preferred_backup_window: str
- :param preferred_backup_window: The daily time range during which
- automated backups are created (if
- enabled). Must be in h24:mi-hh24:mi
- format (UTC).
-
- :type multi_az: bool
- :param multi_az: If True, specifies the DB Instance will be
- deployed in multiple availability zones.
-
- :rtype: :class:`boto.rds.dbinstance.DBInstance`
- :return: The modified db instance.
- """
- params = {'DBInstanceIdentifier' : id}
- if param_group:
- params['DBParameterGroupName'] = param_group
- if security_groups:
- l = []
- for group in security_groups:
- if isinstance(group, DBSecurityGroup):
- l.append(group.name)
- else:
- l.append(group)
- self.build_list_params(params, l, 'DBSecurityGroups.member')
- if preferred_maintenance_window:
- params['PreferredMaintenanceWindow'] = preferred_maintenance_window
- if master_password:
- params['MasterUserPassword'] = master_password
- if allocated_storage:
- params['AllocatedStorage'] = allocated_storage
- if instance_class:
- params['DBInstanceClass'] = instance_class
- if backup_retention_period:
- params['BackupRetentionPeriod'] = backup_retention_period
- if preferred_backup_window:
- params['PreferredBackupWindow'] = preferred_backup_window
- if multi_az:
- params['MultiAZ'] = 'true'
- if apply_immediately:
- params['ApplyImmediately'] = 'true'
-
- return self.get_object('ModifyDBInstance', params, DBInstance)
-
- def delete_dbinstance(self, id, skip_final_snapshot=False,
- final_snapshot_id=''):
- """
- Delete an existing DBInstance.
-
- :type id: str
- :param id: Unique identifier for the new instance.
-
- :type skip_final_snapshot: bool
- :param skip_final_snapshot: This parameter determines whether a final
- db snapshot is created before the instance
- is deleted. If True, no snapshot is created.
- If False, a snapshot is created before
- deleting the instance.
-
- :type final_snapshot_id: str
- :param final_snapshot_id: If a final snapshot is requested, this
- is the identifier used for that snapshot.
-
- :rtype: :class:`boto.rds.dbinstance.DBInstance`
- :return: The deleted db instance.
- """
- params = {'DBInstanceIdentifier' : id}
- if skip_final_snapshot:
- params['SkipFinalSnapshot'] = 'true'
- else:
- params['SkipFinalSnapshot'] = 'false'
- params['FinalDBSnapshotIdentifier'] = final_snapshot_id
- return self.get_object('DeleteDBInstance', params, DBInstance)
-
-
- def reboot_dbinstance(self, id):
- """
- Reboot DBInstance.
-
- :type id: str
- :param id: Unique identifier of the instance.
-
- :rtype: :class:`boto.rds.dbinstance.DBInstance`
- :return: The rebooting db instance.
- """
- params = {'DBInstanceIdentifier' : id}
- return self.get_object('RebootDBInstance', params, DBInstance)
-
- # DBParameterGroup methods
-
- def get_all_dbparameter_groups(self, groupname=None, max_records=None,
- marker=None):
- """
- Get all parameter groups associated with your account in a region.
-
- :type groupname: str
- :param groupname: The name of the DBParameter group to retrieve.
- If not provided, all DBParameter groups will be returned.
-
- :type max_records: int
- :param max_records: The maximum number of records to be returned.
- If more results are available, a MoreToken will
- be returned in the response that can be used to
- retrieve additional records. Default is 100.
-
- :type marker: str
- :param marker: The marker provided by a previous request.
-
- :rtype: list
- :return: A list of :class:`boto.ec2.parametergroup.ParameterGroup`
- """
- params = {}
- if groupname:
- params['DBParameterGroupName'] = groupname
- if max_records:
- params['MaxRecords'] = max_records
- if marker:
- params['Marker'] = marker
- return self.get_list('DescribeDBParameterGroups', params,
- [('DBParameterGroup', ParameterGroup)])
-
- def get_all_dbparameters(self, groupname, source=None,
- max_records=None, marker=None):
- """
- Get all parameters associated with a ParameterGroup
-
- :type groupname: str
- :param groupname: The name of the DBParameter group to retrieve.
-
- :type source: str
- :param source: Specifies which parameters to return.
- If not specified, all parameters will be returned.
- Valid values are: user|system|engine-default
-
- :type max_records: int
- :param max_records: The maximum number of records to be returned.
- If more results are available, a MoreToken will
- be returned in the response that can be used to
- retrieve additional records. Default is 100.
-
- :type marker: str
- :param marker: The marker provided by a previous request.
-
- :rtype: :class:`boto.ec2.parametergroup.ParameterGroup`
- :return: The ParameterGroup
- """
- params = {'DBParameterGroupName' : groupname}
- if source:
- params['Source'] = source
- if max_records:
- params['MaxRecords'] = max_records
- if marker:
- params['Marker'] = marker
- pg = self.get_object('DescribeDBParameters', params, ParameterGroup)
- pg.name = groupname
- return pg
-
- def create_parameter_group(self, name, engine='MySQL5.1', description=''):
- """
- Create a new dbparameter group for your account.
-
- :type name: string
- :param name: The name of the new dbparameter group
-
- :type engine: str
- :param engine: Name of database engine. Must be MySQL5.1 for now.
-
- :type description: string
- :param description: The description of the new security group
-
- :rtype: :class:`boto.rds.dbsecuritygroup.DBSecurityGroup`
- :return: The newly created DBSecurityGroup
- """
- params = {'DBParameterGroupName': name,
- 'Engine': engine,
- 'Description' : description}
- return self.get_object('CreateDBParameterGroup', params, ParameterGroup)
-
- def modify_parameter_group(self, name, parameters=None):
- """
- Modify a parameter group for your account.
-
- :type name: string
- :param name: The name of the new parameter group
-
- :type parameters: list of :class:`boto.rds.parametergroup.Parameter`
- :param parameters: The new parameters
-
- :rtype: :class:`boto.rds.parametergroup.ParameterGroup`
- :return: The newly created ParameterGroup
- """
- params = {'DBParameterGroupName': name}
- for i in range(0, len(parameters)):
- parameter = parameters[i]
- parameter.merge(params, i+1)
- return self.get_list('ModifyDBParameterGroup', params, ParameterGroup)
-
- def reset_parameter_group(self, name, reset_all_params=False, parameters=None):
- """
- Resets some or all of the parameters of a ParameterGroup to the
- default value
-
- :type key_name: string
- :param key_name: The name of the ParameterGroup to reset
-
- :type parameters: list of :class:`boto.rds.parametergroup.Parameter`
- :param parameters: The parameters to reset. If not supplied, all parameters
- will be reset.
- """
- params = {'DBParameterGroupName':name}
- if reset_all_params:
- params['ResetAllParameters'] = 'true'
- else:
- params['ResetAllParameters'] = 'false'
- for i in range(0, len(parameters)):
- parameter = parameters[i]
- parameter.merge(params, i+1)
- return self.get_status('ResetDBParameterGroup', params)
-
- def delete_parameter_group(self, name):
- """
- Delete a DBSecurityGroup from your account.
-
- :type key_name: string
- :param key_name: The name of the DBSecurityGroup to delete
- """
- params = {'DBParameterGroupName':name}
- return self.get_status('DeleteDBParameterGroup', params)
-
- # DBSecurityGroup methods
-
- def get_all_dbsecurity_groups(self, groupname=None, max_records=None,
- marker=None):
- """
- Get all security groups associated with your account in a region.
-
- :type groupnames: list
- :param groupnames: A list of the names of security groups to retrieve.
- If not provided, all security groups will be returned.
-
- :type max_records: int
- :param max_records: The maximum number of records to be returned.
- If more results are available, a MoreToken will
- be returned in the response that can be used to
- retrieve additional records. Default is 100.
-
- :type marker: str
- :param marker: The marker provided by a previous request.
-
- :rtype: list
- :return: A list of :class:`boto.rds.dbsecuritygroup.DBSecurityGroup`
- """
- params = {}
- if groupname:
- params['DBSecurityGroupName'] = groupname
- if max_records:
- params['MaxRecords'] = max_records
- if marker:
- params['Marker'] = marker
- return self.get_list('DescribeDBSecurityGroups', params,
- [('DBSecurityGroup', DBSecurityGroup)])
-
- def create_dbsecurity_group(self, name, description=None):
- """
- Create a new security group for your account.
- This will create the security group within the region you
- are currently connected to.
-
- :type name: string
- :param name: The name of the new security group
-
- :type description: string
- :param description: The description of the new security group
-
- :rtype: :class:`boto.rds.dbsecuritygroup.DBSecurityGroup`
- :return: The newly created DBSecurityGroup
- """
- params = {'DBSecurityGroupName':name}
- if description:
- params['DBSecurityGroupDescription'] = description
- group = self.get_object('CreateDBSecurityGroup', params, DBSecurityGroup)
- group.name = name
- group.description = description
- return group
-
- def delete_dbsecurity_group(self, name):
- """
- Delete a DBSecurityGroup from your account.
-
- :type key_name: string
- :param key_name: The name of the DBSecurityGroup to delete
- """
- params = {'DBSecurityGroupName':name}
- return self.get_status('DeleteDBSecurityGroup', params)
-
- def authorize_dbsecurity_group(self, group_name, cidr_ip=None,
- ec2_security_group_name=None,
- ec2_security_group_owner_id=None):
- """
- Add a new rule to an existing security group.
- You need to pass in either src_security_group_name and
- src_security_group_owner_id OR a CIDR block but not both.
-
- :type group_name: string
- :param group_name: The name of the security group you are adding
- the rule to.
-
- :type ec2_security_group_name: string
- :param ec2_security_group_name: The name of the EC2 security group you are
- granting access to.
-
- :type ec2_security_group_owner_id: string
- :param ec2_security_group_owner_id: The ID of the owner of the EC2 security
- group you are granting access to.
-
- :type cidr_ip: string
- :param cidr_ip: The CIDR block you are providing access to.
- See http://en.wikipedia.org/wiki/Classless_Inter-Domain_Routing
-
- :rtype: bool
- :return: True if successful.
- """
- params = {'DBSecurityGroupName':group_name}
- if ec2_security_group_name:
- params['EC2SecurityGroupName'] = ec2_security_group_name
- if ec2_security_group_owner_id:
- params['EC2SecurityGroupOwnerId'] = ec2_security_group_owner_id
- if cidr_ip:
- params['CIDRIP'] = urllib.quote(cidr_ip)
- return self.get_object('AuthorizeDBSecurityGroupIngress', params, DBSecurityGroup)
-
- def revoke_dbsecurity_group(self, group_name, ec2_security_group_name=None,
- ec2_security_group_owner_id=None, cidr_ip=None):
- """
- Remove an existing rule from an existing security group.
- You need to pass in either ec2_security_group_name and
- ec2_security_group_owner_id OR a CIDR block.
-
- :type group_name: string
- :param group_name: The name of the security group you are removing
- the rule from.
-
- :type ec2_security_group_name: string
- :param ec2_security_group_name: The name of the EC2 security group from which
- you are removing access.
-
- :type ec2_security_group_owner_id: string
- :param ec2_security_group_owner_id: The ID of the owner of the EC2 security
- from which you are removing access.
-
- :type cidr_ip: string
- :param cidr_ip: The CIDR block from which you are removing access.
- See http://en.wikipedia.org/wiki/Classless_Inter-Domain_Routing
-
- :rtype: bool
- :return: True if successful.
- """
- params = {'DBSecurityGroupName':group_name}
- if ec2_security_group_name:
- params['EC2SecurityGroupName'] = ec2_security_group_name
- if ec2_security_group_owner_id:
- params['EC2SecurityGroupOwnerId'] = ec2_security_group_owner_id
- if cidr_ip:
- params['CIDRIP'] = cidr_ip
- return self.get_object('RevokeDBSecurityGroupIngress', params, DBSecurityGroup)
-
- # For backwards compatibility. This method was improperly named
- # in previous versions. I have renamed it to match the others.
- revoke_security_group = revoke_dbsecurity_group
-
- # DBSnapshot methods
-
- def get_all_dbsnapshots(self, snapshot_id=None, instance_id=None,
- max_records=None, marker=None):
- """
- Get information about DB Snapshots.
-
- :type snapshot_id: str
- :param snapshot_id: The unique identifier of an RDS snapshot.
- If not provided, all RDS snapshots will be returned.
-
- :type instance_id: str
- :param instance_id: The identifier of a DBInstance. If provided,
- only the DBSnapshots related to that instance will
- be returned.
- If not provided, all RDS snapshots will be returned.
-
- :type max_records: int
- :param max_records: The maximum number of records to be returned.
- If more results are available, a MoreToken will
- be returned in the response that can be used to
- retrieve additional records. Default is 100.
-
- :type marker: str
- :param marker: The marker provided by a previous request.
-
- :rtype: list
- :return: A list of :class:`boto.rds.dbsnapshot.DBSnapshot`
- """
- params = {}
- if snapshot_id:
- params['DBSnapshotIdentifier'] = snapshot_id
- if instance_id:
- params['DBInstanceIdentifier'] = instance_id
- if max_records:
- params['MaxRecords'] = max_records
- if marker:
- params['Marker'] = marker
- return self.get_list('DescribeDBSnapshots', params,
- [('DBSnapshot', DBSnapshot)])
-
- def create_dbsnapshot(self, snapshot_id, dbinstance_id):
- """
- Create a new DB snapshot.
-
- :type snapshot_id: string
- :param snapshot_id: The identifier for the DBSnapshot
-
- :type dbinstance_id: string
- :param dbinstance_id: The source identifier for the RDS instance from
- which the snapshot is created.
-
- :rtype: :class:`boto.rds.dbsnapshot.DBSnapshot`
- :return: The newly created DBSnapshot
- """
- params = {'DBSnapshotIdentifier' : snapshot_id,
- 'DBInstanceIdentifier' : dbinstance_id}
- return self.get_object('CreateDBSnapshot', params, DBSnapshot)
-
- def delete_dbsnapshot(self, identifier):
- """
- Delete a DBSnapshot
-
- :type identifier: string
- :param identifier: The identifier of the DBSnapshot to delete
- """
- params = {'DBSnapshotIdentifier' : identifier}
- return self.get_object('DeleteDBSnapshot', params, DBSnapshot)
-
- def restore_dbinstance_from_dbsnapshot(self, identifier, instance_id,
- instance_class, port=None,
- availability_zone=None):
-
- """
- Create a new DBInstance from a DB snapshot.
-
- :type identifier: string
- :param identifier: The identifier for the DBSnapshot
-
- :type instance_id: string
- :param instance_id: The source identifier for the RDS instance from
- which the snapshot is created.
-
- :type instance_class: str
- :param instance_class: The compute and memory capacity of the DBInstance.
- Valid values are:
- db.m1.small | db.m1.large | db.m1.xlarge |
- db.m2.2xlarge | db.m2.4xlarge
-
- :type port: int
- :param port: Port number on which database accepts connections.
- Valid values [1115-65535]. Defaults to 3306.
-
- :type availability_zone: str
- :param availability_zone: Name of the availability zone to place
- DBInstance into.
-
- :rtype: :class:`boto.rds.dbinstance.DBInstance`
- :return: The newly created DBInstance
- """
- params = {'DBSnapshotIdentifier' : identifier,
- 'DBInstanceIdentifier' : instance_id,
- 'DBInstanceClass' : instance_class}
- if port:
- params['Port'] = port
- if availability_zone:
- params['AvailabilityZone'] = availability_zone
- return self.get_object('RestoreDBInstanceFromDBSnapshot',
- params, DBInstance)
-
- def restore_dbinstance_from_point_in_time(self, source_instance_id,
- target_instance_id,
- use_latest=False,
- restore_time=None,
- dbinstance_class=None,
- port=None,
- availability_zone=None):
-
- """
- Create a new DBInstance from a point in time.
-
- :type source_instance_id: string
- :param source_instance_id: The identifier for the source DBInstance.
-
- :type target_instance_id: string
- :param target_instance_id: The identifier of the new DBInstance.
-
- :type use_latest: bool
- :param use_latest: If True, the latest snapshot availabile will
- be used.
-
- :type restore_time: datetime
- :param restore_time: The date and time to restore from. Only
- used if use_latest is False.
-
- :type instance_class: str
- :param instance_class: The compute and memory capacity of the DBInstance.
- Valid values are:
- db.m1.small | db.m1.large | db.m1.xlarge |
- db.m2.2xlarge | db.m2.4xlarge
-
- :type port: int
- :param port: Port number on which database accepts connections.
- Valid values [1115-65535]. Defaults to 3306.
-
- :type availability_zone: str
- :param availability_zone: Name of the availability zone to place
- DBInstance into.
-
- :rtype: :class:`boto.rds.dbinstance.DBInstance`
- :return: The newly created DBInstance
- """
- params = {'SourceDBInstanceIdentifier' : source_instance_id,
- 'TargetDBInstanceIdentifier' : target_instance_id}
- if use_latest:
- params['UseLatestRestorableTime'] = 'true'
- elif restore_time:
- params['RestoreTime'] = restore_time.isoformat()
- if dbinstance_class:
- params['DBInstanceClass'] = dbinstance_class
- if port:
- params['Port'] = port
- if availability_zone:
- params['AvailabilityZone'] = availability_zone
- return self.get_object('RestoreDBInstanceToPointInTime',
- params, DBInstance)
-
- # Events
-
- def get_all_events(self, source_identifier=None, source_type=None,
- start_time=None, end_time=None,
- max_records=None, marker=None):
- """
- Get information about events related to your DBInstances,
- DBSecurityGroups and DBParameterGroups.
-
- :type source_identifier: str
- :param source_identifier: If supplied, the events returned will be
- limited to those that apply to the identified
- source. The value of this parameter depends
- on the value of source_type. If neither
- parameter is specified, all events in the time
- span will be returned.
-
- :type source_type: str
- :param source_type: Specifies how the source_identifier should
- be interpreted. Valid values are:
- b-instance | db-security-group |
- db-parameter-group | db-snapshot
-
- :type start_time: datetime
- :param start_time: The beginning of the time interval for events.
- If not supplied, all available events will
- be returned.
-
- :type end_time: datetime
- :param end_time: The ending of the time interval for events.
- If not supplied, all available events will
- be returned.
-
- :type max_records: int
- :param max_records: The maximum number of records to be returned.
- If more results are available, a MoreToken will
- be returned in the response that can be used to
- retrieve additional records. Default is 100.
-
- :type marker: str
- :param marker: The marker provided by a previous request.
-
- :rtype: list
- :return: A list of class:`boto.rds.event.Event`
- """
- params = {}
- if source_identifier and source_type:
- params['SourceIdentifier'] = source_identifier
- params['SourceType'] = source_type
- if start_time:
- params['StartTime'] = start_time.isoformat()
- if end_time:
- params['EndTime'] = end_time.isoformat()
- if max_records:
- params['MaxRecords'] = max_records
- if marker:
- params['Marker'] = marker
- return self.get_list('DescribeEvents', params, [('Event', Event)])
-
-
« no previous file with comments | « third_party/gsutil/20110627/boto/boto/pyami/startup.py ('k') | third_party/gsutil/20110627/boto/boto/rds/dbinstance.py » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698