s3_data_provider.py 文件源码

def _fetch(self, data):
        bucket = self._obtain_s3_connection(
            self.access_key_id,
            self.secret_access_key,
        ).get_bucket(
            self.bucket_name,
        )
        contents = Key(bucket, self.key).get_contents_as_string()
        return json.loads(contents)