(self, bucket_name, key_name)
| 637 | client.delete_object(Bucket=bucket_name, Key=key_name) |
| 638 | |
| 639 | def get_key_contents(self, bucket_name, key_name): |
| 640 | self.wait_until_key_exists(bucket_name, key_name) |
| 641 | client = self._create_client_for_bucket(bucket_name) |
| 642 | response = client.get_object(Bucket=bucket_name, Key=key_name) |
| 643 | return response['Body'].read().decode('utf-8') |
| 644 | |
| 645 | def wait_bucket_exists(self, bucket_name, min_successes=3): |
| 646 | client = self._create_client_for_bucket(bucket_name) |