0

我有一个 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
4

0 回答 0