将 elasticsearch 快照保存在 s3 的文件夹中

如何解决将 elasticsearch 快照保存在 s3 的文件夹中

我有一个 python 脚本，它在 elasticsearch 上拍摄快照并每月将其保存在 s3 存储桶中。 我已经使用了 curator api 。现在我想将快照保存在 s3 存储桶中的子文件夹中，如快照-(dateofsnaphot)。但是我看不到使用 curator api 执行此操作的任何选项。是否可以通过策展人或任何其他方式做到这一点。

 host = os.environ.get('HOST')
    region = os.environ.get('REGION')
    repository_name = os.environ.get('REPOSITORY')
    retention = os.environ.get('RETENTION')
    bucket = os.environ.get('BUCKET')
    role_arn = os.environ.get('ROLE_ARN')
    
    service = 'es'
    credentials = boto3.Session().get_credentials()
    awsauth = AWS4Auth(credentials.access_key,credentials.secret_key,region,service,session_token=credentials.token)
    
    
    def lambda_handler(event,context):
    
        Now = datetime.Now()
        snapshot_prefix = 'automatic-'
        snapshot_name = snapshot_prefix + Now.strftime("%Y%m%d%H%M%s")
    
        # Build the Elasticsearch client.
        es = Elasticsearch(
            hosts=[{'host': host,'port': 443}],http_auth=awsauth,use_ssl=True,verify_certs=True,connection_class=Requestshttpconnection,# Deleting snapshots can take a while,so keep the connection open for long enough to get a response.
            timeout=120
        )
    
        # REGISTER
        try:
            payload = {
                "type": "s3","settings": {
                    "bucket": bucket,"region": region,"role_arn": role_arn
                }
            }
    
            es.snapshot.create_repository(repository_name,json.dumps(payload))
    
        except (ElasticsearchException) as e:
            print(e)
            raise

     # CREATE
    try:
    index_list = curator.IndexList(es)
    index_list.filter_by_age(
        source='creation_date',direction='older',unit='minutes',unit_count=int(retention))

    # Take a new snapshot. This operation can take a while,so we don't want to wait for it to complete.
    curator.Snapshot(index_list,repository=repository_name,name=snapshot_name,wait_for_completion=True).do_action()

except (curator.exceptions.SnapshotInProgress,curator.exceptions.FailedExecution) as e:
    print(e)
raise