dagster-qcloud-cos 0.1.1

腾讯云对象存储与 Dagster 集成

腾讯云对象存储与 Dagster 集成

该 Dagster 集成是为了更便捷的调用腾讯云对象存储，集成提供了一个 Dagster Resource，和一个 Op 。

安装

要安装库，请使用 pip 。

pip install dagster-qcloud-cos -U

Resource

QcloudCosResource

该资源返回一个 CosS3Client 类，该类是腾讯云官方 Python SDK 的类.

可以查看 https://cloud.tencent.com/document/product/436/12269 了解使用方法。

OP

使用 InitCosOperations 类可以为不同的 resource_key 搭建一套各自的 op

from dagster_qcloud_cos import InitCosOperations, QcloudCosResource
from dagster import job, Definitions

# 定义一套依赖于 bucket_a 资源的 op
# 该类会创建一套 required_resource_keys={"bucket_a"} 的 op
bucket_a_ops = InitCosOperations(resource_key="bucket_a")

@job
def upload_file():
    etag, pre_signed_url = bucket_a_ops.op_upload_file()    
    ...(etag, pre_signed_url)

defs = Definitions(
    jobs=[upload_file],
    resources={"bucket_a": QcloudCosResource(BucketId="bucket_a")}
)

或者直接使用预置的 op ，默认操作会使用 resource_key = 'qcloud_cos' 的资源。

from dagster_qcloud_cos import cos_op, QcloudCosResource
from dagster import job, Definitions

@job
def upload_file():
    etag, pre_signed_url = cos_op.op_upload_file()    
    ...(etag, pre_signed_url)

defs = Definitions(
    jobs=[upload_file],
    resources={"qcloud_cos": QcloudCosResource(BucketId="bucket_a")}
)

op_upload_file

上传 5G 大小以内的文件并获取预签名的临时链接

输入：

• key: str, 上传文件KEY
• file: bytes, 文件字节数据
• expired: int, 预签名下载链接的过期时间，0 为不获取，默认为 0
• bucket: str, bucket_id，默认为资源设置的bucket_id

输出：

• etag
• presigned_url: 预签名下载链接，或空字符串