首先需要准备一个角色，授权访问对应的S3 bucket(bucket的创建就不说了)
    角色权限(permissions)如下

    1. {
    2.     "Version": "2012-10-17",
    3.     "Statement": [
    4.         {
    5.             "Action": [
    6.                 "s3:ListBucket"
    7.             ],
    8.             "Effect": "Allow",
    9.             "Resource": [
    10.                 "arn:aws:s3:::YOUR-S3-BUCKET"
    11.             ]
    12.         },
    13.         {
    14.             "Action": [
    15.                 "s3:GetObject",
    16.                 "s3:PutObject",
    17.                 "s3:DeleteObject"
    18.             ],
    19.             "Effect": "Allow",
    20.             "Resource": [
    21.                 "arn:aws:s3:::YOUR-S3-BUCKET/*"
    22.             ]
    23.         }
    24.     ]
    25. }

    信任关系(Trust Relationship)如下

    1. {
    2.   "Version": "2012-10-17",
    3.   "Statement": [
    4.     {
    5.       "Sid": "",
    6.       "Effect": "Allow",
    7.       "Principal": {
    8.         "Service": "es.amazonaws.com"
    9.       },
    10.       "Action": "sts:AssumeRole"
    11.     }
    12.   ]
    13. }

    Python代码如下

    1. import boto3
    2. import requests
    3. from requests_aws4auth import AWS4Auth
    5. region = 'us-east-1'
    6. role_arn_for_snapshot = "YOUR-ROLE-ARN"
    7. s3_bucket_name = "YOUR-S3-BUCKET"
    8. host = 'https://YOUR.DOMAIN.es.amazonaws.com'
    9. repo_name = 'MY-SNAPSHOT'
    11. credentials = boto3.Session().get_credentials()
    12. awsauth = AWS4Auth(
    13.   credentials.access_key,
    14.   credentials.secret_key,
    15.   region,
    16.   "es",
    17.   session_token=credentials.token
    18. )
    20. payload = {
    21.   "type": "s3",
    22.   "settings": {
    23.     "base_path": repo_name,
    24.     "bucket": s3_bucket_name,
    25.     "endpoint": "s3.amazonaws.com",
    26.     "role_arn": role_arn_for_snapshot,
    27.   }
    28. }
    30. # Register repository
    31. r = requests.put(
    32.   '/'.join((host.rstrip('/'), '_snapshot', repo_name)),
    33.   auth=awsauth,
    34.   json=payload,
    35.   headers={"Content-Type": "application/json"}
    36. )
    38. print(r.status_code)
    39. print(r.text)