问题描述
我有一个 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
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)