壓縮解壓
本文介紹如何操作用戶Bucket中的壓縮包和待壓縮文件,包括查看壓縮包內(nèi)容、將壓縮文件進(jìn)行解壓縮處理以及將用戶Bucket內(nèi)的多個(gè)文件進(jìn)行壓縮。適用于各種場(chǎng)景,如數(shù)據(jù)備份、存檔管理、文件傳輸?shù)?。通過(guò)使用這些方法,用戶可以更高效地管理和處理存儲(chǔ)在Bucket中的數(shù)據(jù),提高數(shù)據(jù)傳輸速度、減少存儲(chǔ)空間占用,以及方便地進(jìn)行文件歸檔和共享。
功能簡(jiǎn)介
智能媒體管理服務(wù)提供了云上資源的壓縮和解壓縮功能,該功能幫助用戶高效、便捷地進(jìn)行云上文件管理,用戶可以根據(jù)需要使用該功能對(duì)OSS中的文件進(jìn)行在線壓縮和解壓縮。
前提條件
已創(chuàng)建并獲取AccessKey。具體操作,請(qǐng)參見創(chuàng)建AccessKey。
已開通OSS服務(wù)、創(chuàng)建存儲(chǔ)空間并上傳文件到存儲(chǔ)空間。具體操作,請(qǐng)參見控制臺(tái)上傳文件。
已開通智能媒體管理服務(wù)。具體操作,請(qǐng)參見開通產(chǎn)品。
已通過(guò)智能媒體管理控制臺(tái)創(chuàng)建項(xiàng)目。具體操作,請(qǐng)參見創(chuàng)建項(xiàng)目。
說(shuō)明您也可以調(diào)用API接口創(chuàng)建項(xiàng)目。具體操作,請(qǐng)參見CreateProject - 創(chuàng)建項(xiàng)目。
您可以調(diào)用ListProjects - 列出所有項(xiàng)目信息的列表接口列出指定地域下已創(chuàng)建的所有項(xiàng)目信息。
注意事項(xiàng)
壓縮、查看壓縮包內(nèi)容、解壓縮各任務(wù)開始執(zhí)行后,任務(wù)信息只保存7天,超過(guò)7天則無(wú)法再獲取。您可以通過(guò)以下四種方式及時(shí)獲取任務(wù)信息:
調(diào)用GetTask - 獲取任務(wù)信息或ListTasks - 列出任務(wù)接口獲取返回的
TaskId
,查看任務(wù)信息。在與智能媒體管理相同的地域下開通MNS服務(wù),并配置訂閱關(guān)系,及時(shí)獲取任務(wù)信息通知,異步通知消息格式請(qǐng)參見異步通知消息格式。關(guān)于MNS SDK的更多信息,請(qǐng)參見步驟四:接收和刪除消息。
在與智能媒體管理相同的地域下開通RocketMQ服務(wù),并創(chuàng)建RocketMQ 4.0實(shí)例、Topic、Group,及時(shí)獲取任務(wù)信息通知,異步通知消息格式請(qǐng)參見異步通知消息格式。關(guān)于RocketMQ使用的更多信息,請(qǐng)參見調(diào)用HTTP協(xié)議的SDK收發(fā)普通消息。
在與智能媒體管理相同的地域下開通并接入事件總線EventBridge服務(wù),及時(shí)獲取任務(wù)信息通知。更多信息,請(qǐng)參見智能媒體管理IMM事件。
壓縮
調(diào)用CreateFileCompressionTask - 創(chuàng)建文件壓縮任務(wù)接口將OSS Bucket中的多個(gè)文件進(jìn)行壓縮處理。
壓縮信息
項(xiàng)目名稱:test-project
待壓縮文件:
oss://test-bucket/test-object1.jpg
oss://test-bucket/test-object2.jpg
oss://test-bucket/test-object3.jpg
oss://test-bucket/test-object4.jpg
輸出壓縮文件的OSS地址:oss://test-bucket/test-target-object.zip
請(qǐng)求示例
{
"ProjectName": "test-project",
"CompressedFormat": "zip",
"Sources": "[{\"URI\":\"oss://test-bucket/test-object1.jpg\"},{\"URI\":\"oss://test-bucket/test-object2.jpg\"},{\"URI\":\"oss://test-bucket/test-object3.jpg\"},{\"URI\":\"oss://test-bucket/test-object4.jpg\"}]",
"TargetURI": "oss://test-bucket/test-target-object.zip"
}
返回示例
{
"TaskId": "FileCompression-7e3e2b8c-81bd-495f-a338-25b3762a****",
"RequestId": "C54C5888-9C96-5A35-AF73-ABD6EF15****",
"EventId": "164-1S6uXTYhUU4qAFCPOTcYdcb****"
}
示例代碼
壓縮文件的完整示例代碼如下。
# -*- coding: utf-8 -*-
# This file is auto-generated, don't edit it. Thanks.
import os
import sys
from typing import List
from alibabacloud_imm20200930.client import Client as imm20200930Client
from alibabacloud_tea_openapi import models as open_api_models
from alibabacloud_imm20200930 import models as imm_20200930_models
from alibabacloud_tea_util import models as util_models
from alibabacloud_tea_util.client import Client as UtilClient
class Sample:
def __init__(self):
pass
@staticmethod
def create_client(
access_key_id: str,
access_key_secret: str,
) -> imm20200930Client:
"""
使用AccessKey ID&AccessKey Secret初始化賬號(hào)Client。
@param access_key_id:
@param access_key_secret:
@return: Client
@throws Exception
"""
config = open_api_models.Config(
access_key_id=access_key_id,
access_key_secret=access_key_secret
)
# 填寫訪問(wèn)的IMM域名。
config.endpoint = f'imm.cn-beijing.aliyuncs.com'
return imm20200930Client(config)
@staticmethod
def main(
args: List[str],
) -> None:
# 阿里云賬號(hào)AccessKey擁有所有API的訪問(wèn)權(quán)限,建議您使用RAM用戶進(jìn)行API訪問(wèn)或日常運(yùn)維。
# 強(qiáng)烈建議不要把AccessKey ID和AccessKey Secret保存到工程代碼里,否則可能導(dǎo)致AccessKey泄露,威脅您賬號(hào)下所有資源的安全。
# 本示例通過(guò)從環(huán)境變量中讀取AccessKey,來(lái)實(shí)現(xiàn)API訪問(wèn)的身份驗(yàn)證。如何配置環(huán)境變量,請(qǐng)參見http://m.bestwisewords.com/document_detail/2361894.html。
imm_access_key_id = os.getenv("AccessKeyId")
imm_access_key_secret = os.getenv("AccessKeySecret")
client = Sample.create_client(imm_access_key_id, imm_access_key_secret)
sources_0 = imm_20200930_models.CreateFileCompressionTaskRequestSources(
uri='oss://test-bucket/test-object1.jpg'
)
sources_1 = imm_20200930_models.CreateFileCompressionTaskRequestSources(
uri='oss://test-bucket/test-object2.jpg'
)
sources_2 = imm_20200930_models.CreateFileCompressionTaskRequestSources(
uri='oss://test-bucket/test-object3.jpg'
)
sources_3 = imm_20200930_models.CreateFileCompressionTaskRequestSources(
uri='oss://test-bucket/test-object4.jpg'
)
create_file_compression_task_request = imm_20200930_models.CreateFileCompressionTaskRequest(
project_name='test-project',
sources=[
sources_0,
sources_1,
sources_2,
sources_3
],
target_uri='oss://test-bucket/test-target-object.zip',
compressed_format='zip',
)
runtime = util_models.RuntimeOptions()
try:
# 復(fù)制代碼運(yùn)行請(qǐng)自行打印API的返回值。
client.create_file_compression_task_with_options(create_file_compression_task_request, runtime)
except Exception as error:
# 如有需要,請(qǐng)打印錯(cuò)誤信息。
UtilClient.assert_as_string(error.message)
@staticmethod
async def main_async(
args: List[str],
) -> None:
# 阿里云賬號(hào)AccessKey擁有所有API的訪問(wèn)權(quán)限,建議您使用RAM用戶進(jìn)行API訪問(wèn)或日常運(yùn)維。
# 強(qiáng)烈建議不要把AccessKey ID和AccessKey Secret保存到工程代碼里,否則可能導(dǎo)致AccessKey泄露,威脅您賬號(hào)下所有資源的安全。
# 本示例通過(guò)從環(huán)境變量中讀取AccessKey,來(lái)實(shí)現(xiàn)API訪問(wèn)的身份驗(yàn)證。如何配置環(huán)境變量,請(qǐng)參見http://m.bestwisewords.com/document_detail/2361894.html。
imm_access_key_id = os.getenv("AccessKeyId")
imm_access_key_secret = os.getenv("AccessKeySecret")
client = Sample.create_client(imm_access_key_id, imm_access_key_secret)
sources_0 = imm_20200930_models.CreateFileCompressionTaskRequestSources(
uri='oss://test-bucket/test-object1.jpg'
)
sources_1 = imm_20200930_models.CreateFileCompressionTaskRequestSources(
uri='oss://test-bucket/test-object2.jpg'
)
sources_2 = imm_20200930_models.CreateFileCompressionTaskRequestSources(
uri='oss://test-bucket/test-object3.jpg'
)
sources_3 = imm_20200930_models.CreateFileCompressionTaskRequestSources(
uri='oss://test-bucket/test-object4.jpg'
)
create_file_compression_task_request = imm_20200930_models.CreateFileCompressionTaskRequest(
project_name='test-project',
sources=[
sources_0,
sources_1,
sources_2,
sources_3
],
target_uri='oss://test-bucket/test-target-object.zip',
compressed_format='zip',
)
runtime = util_models.RuntimeOptions()
try:
# 復(fù)制代碼運(yùn)行請(qǐng)自行打印API的返回值。
await client.create_file_compression_task_with_options_async(create_file_compression_task_request, runtime)
except Exception as error:
# 如有需要,請(qǐng)打印錯(cuò)誤信息。
UtilClient.assert_as_string(error.message)
if __name__ == '__main__':
Sample.main(sys.argv[1:])
查看壓縮包內(nèi)容
調(diào)用CreateArchiveFileInspectionTask - 創(chuàng)建壓縮包解析任務(wù)接口查看OSS壓縮包內(nèi)容。
壓縮包信息
項(xiàng)目名稱:test-project
壓縮包路徑:oss://test-bucket/test-target-object.zip
任務(wù)執(zhí)行結(jié)果保存地址:oss://test-bucket/test-target-object.json
請(qǐng)求示例
{
"ProjectName": "test-project",
"SourceURI": "oss://test-bucket/test-target-object.zip",
"TargetURI": "oss://test-bucket/test-target-object.json"
}
返回示例
{
"TaskId": "ArchiveFileInspection-4a7c308a-5671-4d34-ba41-86a942d0****",
"RequestId": "20D23855-C9E6-5193-8939-3A8797E1****",
"EventId": "2AB-1S53L6FTdU6yMxkc1JgpwcV****"
}
示例代碼
查看壓縮包內(nèi)容的完整示例代碼如下。
# -*- coding: utf-8 -*-
# This file is auto-generated, don't edit it. Thanks.
import os
import sys
from typing import List
from alibabacloud_imm20200930.client import Client as imm20200930Client
from alibabacloud_tea_openapi import models as open_api_models
from alibabacloud_imm20200930 import models as imm_20200930_models
from alibabacloud_tea_util import models as util_models
from alibabacloud_tea_util.client import Client as UtilClient
class Sample:
def __init__(self):
pass
@staticmethod
def create_client(
access_key_id: str,
access_key_secret: str,
) -> imm20200930Client:
"""
使用AccessKey ID&AccessKey Secret初始化賬號(hào)Client。
@param access_key_id:
@param access_key_secret:
@return: Client
@throws Exception
"""
config = open_api_models.Config(
access_key_id=access_key_id,
access_key_secret=access_key_secret
)
# 填寫訪問(wèn)的IMM域名。
config.endpoint = f'imm.cn-beijing.aliyuncs.com'
return imm20200930Client(config)
@staticmethod
def main(
args: List[str],
) -> None:
# 阿里云賬號(hào)AccessKey擁有所有API的訪問(wèn)權(quán)限,建議您使用RAM用戶進(jìn)行API訪問(wèn)或日常運(yùn)維。
# 強(qiáng)烈建議不要把AccessKey ID和AccessKey Secret保存到工程代碼里,否則可能導(dǎo)致AccessKey泄露,威脅您賬號(hào)下所有資源的安全。
# 本示例通過(guò)從環(huán)境變量中讀取AccessKey,來(lái)實(shí)現(xiàn)API訪問(wèn)的身份驗(yàn)證。如何配置環(huán)境變量,請(qǐng)參見http://m.bestwisewords.com/document_detail/2361894.html。
imm_access_key_id = os.getenv("AccessKeyId")
imm_access_key_secret = os.getenv("AccessKeySecret")
client = Sample.create_client(imm_access_key_id, imm_access_key_secret)
create_archive_file_inspection_task_request = imm_20200930_models.CreateArchiveFileInspectionTaskRequest(
project_name='test-project',
source_uri='oss://test-bucket/test-target-object.zip',
target_uri='oss://test-bucket/test-target-object.json'
)
runtime = util_models.RuntimeOptions()
try:
# 復(fù)制代碼運(yùn)行請(qǐng)自行打印API的返回值。
client.create_archive_file_inspection_task_with_options(create_archive_file_inspection_task_request, runtime)
except Exception as error:
# 如有需要,請(qǐng)打印錯(cuò)誤信息。
UtilClient.assert_as_string(error.message)
@staticmethod
async def main_async(
args: List[str],
) -> None:
# 阿里云賬號(hào)AccessKey擁有所有API的訪問(wèn)權(quán)限,建議您使用RAM用戶進(jìn)行API訪問(wèn)或日常運(yùn)維。
# 強(qiáng)烈建議不要把AccessKey ID和AccessKey Secret保存到工程代碼里,否則可能導(dǎo)致AccessKey泄露,威脅您賬號(hào)下所有資源的安全。
# 本示例通過(guò)從環(huán)境變量中讀取AccessKey,來(lái)實(shí)現(xiàn)API訪問(wèn)的身份驗(yàn)證。如何配置環(huán)境變量,請(qǐng)參見http://m.bestwisewords.com/document_detail/2361894.html。
imm_access_key_id = os.getenv("AccessKeyId")
imm_access_key_secret = os.getenv("AccessKeySecret")
client = Sample.create_client(imm_access_key_id, imm_access_key_secret)
create_archive_file_inspection_task_request = imm_20200930_models.CreateArchiveFileInspectionTaskRequest(
project_name='test-project',
source_uri='oss://test-bucket/test-target-object.zip',
target_uri='oss://test-bucket/test-target-object.json',
)
runtime = util_models.RuntimeOptions()
try:
# 復(fù)制代碼運(yùn)行請(qǐng)自行打印API的返回值。
await client.create_archive_file_inspection_task_with_options_async(create_archive_file_inspection_task_request, runtime)
except Exception as error:
# 如有需要,請(qǐng)打印錯(cuò)誤信息。
UtilClient.assert_as_string(error.message)
if __name__ == '__main__':
Sample.main(sys.argv[1:])
解壓縮
調(diào)用CreateFileUncompressionTask - 創(chuàng)建解壓縮任務(wù)接口對(duì)OSS中的壓縮包進(jìn)行解壓縮處理。
解壓縮信息
項(xiàng)目名稱:test-project
壓縮包路徑:oss://test-bucket/test-target-object.zip
待解壓縮文件:test-object1.jpg
解壓縮文件的存放路徑:oss://test-bucket/test-target-object
請(qǐng)求示例
{
"ProjectName": "test-project",
"SourceURI": "oss://test-bucket/test-target-object.zip",
"Target": "{\"URI\":\"oss://test-bucket/test-target-object\"}",
"SelectedFiles": "[\"test-object1.jpg\"]"
}
返回示例
{
"TaskId": "FileUncompression-f31061ab-eaeb-469d-ac8f-9af10e5d****",
"RequestId": "20115435-9F59-58C0-8D15-E6ECC096****",
"EventId": "3B6-1S6ywKAB2ogXJnrzmk6tFUF****"
}
示例代碼
FAQ
通過(guò)CreateFileCompressionTask接口創(chuàng)建zip成功后,需要多久才能獲取到壓縮后的zip文件?
可以通過(guò)GetTask - 獲取任務(wù)信息接口輪詢?nèi)蝿?wù)狀態(tài),或者通過(guò)異步任務(wù)MNS消息處理示例異步接收成功的消息。