diff options
author | Daniel G. Taylor <dan@programmer-art.org> | 2014-09-02 10:26:59 -0700 |
---|---|---|
committer | Daniel G. Taylor <dan@programmer-art.org> | 2014-09-02 10:26:59 -0700 |
commit | 3ba380f0e2098d7d475225e3b75deb3cb4b59384 (patch) | |
tree | 94c7cb69e431f938d8fcc3fecf19b816b63aed89 /boto | |
parent | ac2b311c04cb49b337ba033b1a550039c12c929d (diff) | |
parent | 0e762624c4e6de6e6b763f0e90ffc5f77151f041 (diff) | |
download | boto-3ba380f0e2098d7d475225e3b75deb3cb4b59384.tar.gz |
Merge pull request #2542 from cloudregistry/r53_list_rrsets_paging_fix
Truncated Response Handling in Route53 ListResourceRecordSets. Fixes #2542.
Diffstat (limited to 'boto')
-rw-r--r-- | boto/route53/connection.py | 2 | ||||
-rw-r--r-- | boto/route53/record.py | 11 |
2 files changed, 9 insertions, 4 deletions
diff --git a/boto/route53/connection.py b/boto/route53/connection.py index 2cab2359..7ca6df86 100644 --- a/boto/route53/connection.py +++ b/boto/route53/connection.py @@ -383,7 +383,7 @@ class Route53Connection(AWSAuthConnection): """ params = {'type': type, 'name': name, - 'Identifier': identifier, 'maxitems': maxitems} + 'identifier': identifier, 'maxitems': maxitems} uri = '/%s/hostedzone/%s/rrset' % (self.Version, hosted_zone_id) response = self.make_request('GET', uri, params=params) body = response.read() diff --git a/boto/route53/record.py b/boto/route53/record.py index 664739b8..b8c69d44 100644 --- a/boto/route53/record.py +++ b/boto/route53/record.py @@ -54,6 +54,7 @@ class ResourceRecordSets(ResultSet): self.changes = [] self.next_record_name = None self.next_record_type = None + self.next_record_identifier = None super(ResourceRecordSets, self).__init__([('ResourceRecordSet', Record)]) def __repr__(self): @@ -165,12 +166,14 @@ class ResourceRecordSets(ResultSet): return self.connection.change_rrsets(self.hosted_zone_id, self.to_xml()) def endElement(self, name, value, connection): - """Overwritten to also add the NextRecordName and - NextRecordType to the base object""" + """Overwritten to also add the NextRecordName, + NextRecordType and NextRecordIdentifier to the base object""" if name == 'NextRecordName': self.next_record_name = value elif name == 'NextRecordType': self.next_record_type = value + elif name == 'NextRecordIdentifier': + self.next_record_identifier = value else: return super(ResourceRecordSets, self).endElement(name, value, connection) @@ -183,7 +186,9 @@ class ResourceRecordSets(ResultSet): yield obj if self.is_truncated: self.is_truncated = False - results = self.connection.get_all_rrsets(self.hosted_zone_id, name=self.next_record_name, type=self.next_record_type) + results = self.connection.get_all_rrsets(self.hosted_zone_id, name=self.next_record_name, + type=self.next_record_type, + identifier=self.next_record_identifier) else: results = None self.is_truncated = truncated |