如何使用bot3 waiters从大型RDS实例中获取快照

Question

我开始将我的代码迁移到boto 3，我注意到一个不错的补充是服务员。

我想从db实例创建一个快照，并在继续使用代码之前检查它的可用性。

我的做法如下：

# Notice: Step : Check snapshot availability [1st account - Oregon]
print "--- Check snapshot availability [1st account - Oregon] ---"
new_snap = client1.describe_db_snapshots(DBSnapshotIdentifier=new_snapshot_name)['DBSnapshots'][0]
# print pprint.pprint(new_snap) #debug


waiter = client1.get_waiter('db_snapshot_completed')
print "Manual snapshot is -pending-"
sleep(60)
waiter.wait(
                DBSnapshotIdentifier = new_snapshot_name,
                IncludeShared = True,
                IncludePublic = False
            )

print "OK. Manual snapshot is -available-"

，但文件上说，它每15秒对状态进行40次轮询。那是10分钟。然而，一个相当大的数据库将需要更多。

我怎么能用服务员来减轻这一点呢？

Answer 1

我认为另一个答案暗示了这一解决办法，但在这里它是明确的。

[snip]
...
# Create your waiter
waiter_db_snapshot = client1.get_waiter('db_snapshot_completed')

# Increase the max number of tries as appropriate
waiter_db_snapshot.config.max_attempts = 120

# Add a 60 second delay between attempts
waiter_db_snapshot.config.delay = 60

print "Manual snapshot is -pending-"
....
[snip]

Answer 2

如果你愿意的话，你可以不用服务员。

根据该服务员的文档：每隔15秒轮询RDS.Client.description_db_snapshots（），直到达到成功状态。检查失败40次后返回错误。

基本上，这意味着它可以执行以下操作：

RDS = boto3.client('rds')
RDS.describe_db_snapshots()

您可以直接运行它，但要过滤到快照id，下面是语法。http://boto3.readthedocs.io/en/latest/reference/services/rds.html#RDS.Client.describe_db_snapshots

response = client.describe_db_snapshots(
    DBInstanceIdentifier='string',
    DBSnapshotIdentifier='string',
    SnapshotType='string',
    Filters=[
        {
            'Name': 'string',
            'Values': [
                'string',
            ]
        },
    ],
    MaxRecords=123,
    Marker='string',
    IncludeShared=True|False,
    IncludePublic=True|False
)

这将最终看起来像这样：

snapshot_description = RDS.describe_db_snapshots(DBSnapshotIdentifier='YOURIDHERE')

然后您可以循环，直到返回可用的快照。所以这里有一个非常粗略的想法。

 import boto3
 import time
 RDS = boto3.client('rds')
 RDS.describe_db_snapshots()
 snapshot_description = RDS.describe_db_snapshots(DBSnapshotIdentifier='YOURIDHERE')
 while snapshot_description['DBSnapshots'][0]['Status'] != 'available' :
     print("still waiting")
     time.sleep(15)    
     snapshot_description = RDS.describe_db_snapshots(DBSnapshotIdentifier='YOURIDHERE')

Answer 3

服务员有配置参数'延迟'和'max_attempts'如下：

waiter = rds_client.get_waiter('db_instance_available')
print( "waiter delay: " + str(waiter.config.delay) )

waiter.pygithub