Skip to content

Update ci sdk and demo #248

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Aug 7, 2023
Merged

Update ci sdk and demo #248

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
604924b
Update ci sdk and demo
fly-zll Aug 7, 2023
406cfae
Merge remote-tracking branch 'origin/master'
fly-zll Aug 7, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
118 changes: 115 additions & 3 deletions demo/ci_media.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@
client = CosS3Client(config)


bucket_name = 'demo-1253960454'
bucket_name = 'demo-1250000000'


def ci_get_media_bucket():
Expand Down Expand Up @@ -1051,7 +1051,7 @@ def ci_create_segment_video_body_jobs():
# Foreground（输出前景视频）、
# Combination（输出抠图后的前景与自定义背景合成后的视频）
'Mode': 'Mask',
# 非必选 抠图模式，当前支持 HumanSeg、GreenScreenSeg。 默认值 HumanSeg
# 非必选 抠图模式，当前支持 HumanSeg（人像抠图）、GreenScreenSeg（绿幕抠图）、SolidColorSeg（纯色背景抠图）。 默认值 HumanSeg
# 'SegmentType': 'GreenScreenSeg',
# 非必选 mode为Foreground时可指定此参数，背景颜色为蓝色，取值范围为0-255, 默认值为0
# 'BackgroundBlue': '255',
Expand All @@ -1062,7 +1062,13 @@ def ci_create_segment_video_body_jobs():
# 非必选 mode为Combination时，必需指定此参数，传入背景文件，背景文件需与object在同存储桶下
# 'BackgroundLogoUrl': 'http://testpic-1253960454.cos.ap-chongqing.myqcloud.com'
# 非必选 阈值 可以调整alpha通道的边缘，调整抠图的边缘位置 取值范围为0-255, 默认值为0
# 'BinaryThreshold': '200'
# 'BinaryThreshold': '200',
# 非必选 纯色背景抠图的背景色（红）, 当 SegmentType 为 SolidColorSeg 生效，取值范围为0-255，默认值为 0
# 'RemoveRed': '200',
# 非必选 纯色背景抠图的背景色（绿）, 当 SegmentType 为 SolidColorSeg 生效，取值范围为0-255，默认值为 0
# 'RemoveGreen': '200',
# 非必选 纯色背景抠图的背景色（蓝）, 当 SegmentType 为 SolidColorSeg 生效，取值范围为0-255，默认值为 0
# 'RemoveBlue': '200'
},
# 输出配置
'Output': {
Expand Down Expand Up @@ -1494,6 +1500,112 @@ def ci_create_image_inspect_jobs():
return response


def ci_create_image_inspect_batch_jobs():
# 创建异常图片检测批量处理任务
body = {
# 批量任务名称
# 存量触发任务名称，支持中文、英文、数字、—和_，长度限制128字符
# 必选
'Name': 'image-inspect-auto-move-batch-process',
# 批量处理任务类型：
# 支持 Job（独立异步任务） Workflow（工作流）
'Type': 'Job',
# 待操作的对象信息
# 必传参数
'Input': {
# 'UrlFile': 'https://ziroom-tech-1255976291.cos.ap-beijing.myqcloud.com/ci_ziroom-tech_scankey_url.txt',
# Object 前缀
'Prefix': '/',
},
# 操作规则
# 必传参数
'Operation': {
# 按对象的last modify时间过滤的触发范围，若传入此参数，则当前任务仅处理指定事件范围内的对象
# 非必传
# 创建的任务类型，此处固定值为ImageInspect
# 必传参数
'Tag': 'ImageInspect',
# 任务参数集合
# 必传参数
'JobParam': {
# 异常图片检测配置
# 非必选
'ImageInspect': {
# 是否开启检测到异常图片检测后自动对图片进行处理的动作，false/true，非必选，默认false
'AutoProcess': 'true',
# 在检测到为异常图片后的处理动作，有效值为：
# BackupObject：移动图片到固定目录下，目录名为abnormal_images_backup/，由后台自动创建
# SwitchObjectToPrivate：将图片权限设置为私有
# DeleteObject：删除图片
# 非必选参数，默认值为BackupObject
'ProcessType': 'BackupObject'
},
},

},

}
response = client.ci_create_inventory_trigger_jobs(
Bucket=bucket_name,
JobBody=body,
ContentType='application/xml'
)
print(response)
return response


def ci_create_image_inspect_workflow_batch_jobs():
# 创建异常图片检测工作流批量处理任务

body = {
# 批量任务名称
# 存量触发任务名称，支持中文、英文、数字、—和_，长度限制128字符
# 必选
'Name': 'image-inspect-auto-move-batch-process',
# 批量处理任务类型：
# 支持 Job（独立异步任务） Workflow（工作流）
'Type': 'Workflow',
# 待操作的对象信息
# 必传参数
'Input': {
# 'UrlFile': 'https://ziroom-tech-1255976291.cos.ap-beijing.myqcloud.com/ci_ziroom-tech_scankey_url.txt',
# Object 前缀
'Prefix': '/',
},
# 操作规则
# 必传参数
'Operation': {
# 按对象的last modify时间过滤的触发范围，若传入此参数，则当前任务仅处理指定事件范围内的对象
# 非必传
'TimeInterval': {
'Start': '2023-05-01T00:00:00+0800',
'End': '2023-06-01T00:00:00+0800'
},
# 创建的任务类型，此处固定值为ImageInspect
# 必传参数
'WorkflowIds': 'w2504f47ad46exxxxxxxxxxxxxx',
},

}
response = client.ci_create_inventory_trigger_jobs(
Bucket=bucket_name,
JobBody=body,
ContentType='application/xml'
)
print(response)
return response


def ci_delete_inventory_trigger_jobs():
# 删除指定的批量处理任务
response = client.ci_delete_inventory_trigger_jobs(
Bucket=bucket_name, # 桶名称
JobId='b97c37f492adf11xxxxxxxxxxxx', # 需要删除的工作流ID
)
print(response)
return response


if __name__ == "__main__":
# ci_get_media_queue()
# ci_get_media_transcode_jobs()
Expand Down
101 changes: 101 additions & 0 deletions qcloud_cos/cos_client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -9277,6 +9277,107 @@ def ci_cancel_jobs(self, Bucket, JobID, **kwargs):
logger.debug("ci_cancel_jobs:%s", rt.content)
return ''

def ci_create_inventory_trigger_jobs(self, Bucket, JobBody, **kwargs):
""" 创建批量处理任务接口 https://cloud.tencent.com/document/product/460/80155
:param Bucket(string): 存储桶名称.
:param JobBody(dict): 创建批量处理任务的配置.
:param kwargs(dict): 设置请求的headers.
:return(dict): 查询成功返回的结果,dict类型.
.. code-block:: python
config = CosConfig(Region=region, SecretId=secret_id, SecretKey=secret_key, Token=token) # 获取配置对象
client = CosS3Client(config)
# 创建任务接口
response = client.ci_create_inventory_trigger_jobs(
Bucket='bucket'
JobBody={},
)
print response
"""
headers = mapped(kwargs)
final_headers = {}
params = {}
for key in headers:
if key.startswith("response"):
params[key] = headers[key]
else:
final_headers[key] = headers[key]
headers = final_headers

params = format_values(params)
xml_config = format_xml(data=JobBody, root='Request')
path = "/inventorytriggerjob"
url = self._conf.uri(bucket=Bucket, path=path, endpoint=self._conf._endpoint_ci)
logger.info("ci_create_inventory_trigger_jobs result, url=:{url} ,headers=:{headers}, params=:{params}, xml_config=:{xml_config}".format(
url=url,
headers=headers,
params=params,
xml_config=xml_config))
rt = self.send_request(
method='POST',
url=url,
bucket=Bucket,
data=xml_config,
auth=CosS3Auth(self._conf, path, params=params),
params=params,
headers=headers,
ci_request=True)

data = xml_to_dict(rt.content)
# 单个元素时将dict转为list
format_dict(data, ['JobsDetail'])
return data

def ci_delete_inventory_trigger_jobs(self, Bucket, JobId, **kwargs):
""" 取消指定批量任务接口 https://cloud.tencent.com/document/product/460/76892

:param Bucket(string): 存储桶名称.
:param JobId(string): 需要取消的批量任务ID.
:param kwargs(dict): 设置请求的headers.
:return(dict): 查询成功返回的结果,dict类型.

.. code-block:: python

config = CosConfig(Region=region, SecretId=secret_id, SecretKey=secret_key, Token=token) # 获取配置对象
client = CosS3Client(config)
# 更新工作流状态接口
response = client.ci_delete_inventory_trigger_jobs(
Bucket='bucket'
JobId='',
)
print response
"""
headers = mapped(kwargs)
final_headers = {}
params = {}
for key in headers:
if key.startswith("response"):
params[key] = headers[key]
else:
final_headers[key] = headers[key]
headers = final_headers

params = format_values(params)

path = "/inventorytriggerjob/" + JobId
url = self._conf.uri(bucket=Bucket, path=path, endpoint=self._conf._endpoint_ci)
url = url + '?cancel'
logger.info("ci_delete_inventory_trigger_jobs result, url=:{url} ,headers=:{headers}, params=:{params}".format(
url=url,
headers=headers,
params=params))
rt = self.send_request(
method='PUT',
url=url,
bucket=Bucket,
auth=CosS3Auth(self._conf, path, params=params),
params=params,
headers=headers,
ci_request=True)

data = xml_to_dict(rt.content)
# 单个元素时将dict转为list
return data


if __name__ == "__main__":
pass