创建数据管道 - 对象存储 OSS

通过 do-data-pipe-line-action 命令发送 putDataPipelineConfiguration 操作，创建一条数据管道（DataPipeline）规则。规则创建后，OSS 自动调用您的阿里云百炼对源 Bucket 中的原始数据进行向量化并写入向量 Bucket。

命令格式

ossutil api do-data-pipe-line-action --action putDataPipelineConfiguration \
  --parameters dataPipelineName=my-data-pipeline \
  --parameters role=acs:ram::<AccountId>:role/my-data-pipeline-role \
  --body file://config.xml \
  --region cn-hangzhou

参数说明

参数	类型	说明
--action	string	要发送的数据管道操作名称。
--parameters	stringArray	请求的查询参数，k=v 格式，可重复指定。例如 dataPipelineName=my-data-pipeline、role=acs:ram::<AccountId>:role/my-data-pipeline-role。
--body	string	请求体内容，file:// 表示从文件读取（仅 putDataPipelineConfiguration 需要，内容为 DataPipelineConfiguration XML）。
--region	string	Bucket 所在地域，例如 cn-hangzhou。
-i, --access-key-id / -k, --access-key-secret	string	访问 OSS 使用的 AccessKey ID 与 Secret（也可通过 ossutil config 预先配置）。

关于支持的全局命令行选项，请参见 ossutil 支持的全局命令行选项。

使用示例

先将数据管道配置写入 config.xml：

<?xml version="1.0" encoding="UTF-8" ?>
<DataPipelineConfiguration>
  <Sources>
      <InputBucket>my-bucket</InputBucket>
      <InputDataScope>All</InputDataScope>
  </Sources>
  <DataPipelineEmbeddingConfiguration>
      <EmbeddingProvider>bailian</EmbeddingProvider>
      <ApiKey>sk-xxxx</ApiKey>
      <Model>qwen2.5-vl-embedding</Model>
  </DataPipelineEmbeddingConfiguration>
  <Destination>
      <VectorBucketName>my-vector-bucket</VectorBucketName>
      <VectorIndexNames>my-index</VectorIndexNames>
  </Destination>
  <DataPipelineError>
      <ErrorMode>ignore</ErrorMode>
  </DataPipelineError>
</DataPipelineConfiguration>

再执行命令创建数据管道：

ossutil api do-data-pipe-line-action --action putDataPipelineConfiguration \
  --parameters dataPipelineName=my-data-pipeline \
  --parameters role=acs:ram::<AccountId>:role/my-data-pipeline-role \
  --body file://config.xml \
  --region cn-hangzhou