文档首页 > > SQL语法参考> 数据定义语句> 创建输出流> DDS输出流

DDS输出流

分享
更新时间:2020/09/29 GMT+08:00

概述

CS将作业的输出数据输出到文档数据库服务(DDS)中。

文档数据库服务(Document Database Service,简称DDS)完全兼容MongoDB协议,提供安全、高可用、高可靠、弹性伸缩和易用的数据库服务,同时提供一键部署、弹性扩容、容灾、备份、恢复、监控和告警等功能。DDS的更多信息,请参见《文档数据库服务用户指南》

前提条件

  • 请务必确保您的账户下已在文档数据库服务(DDS)里创建了DDS实例。

    如何创建DDS实例,请参考《文档数据库服务快速入门》“快速购买文档数据库实例”章节。

  • 目前仅支持未开启SSL认证的集群实例,不支持副本集与单节点的类型实例。
  • 该场景作业需要运行在CS的独享集群上,请确保已创建CS独享集群。

    如何创建CS独享集群,具体操作请参见《实时流计算服务用户指南》集群管理章节。

  • 确保CS独享集群与DDS集群建立对等连接,且用户可以根据实际所需设置相应安全组规则。

    如何建立VPC对等连接,请参考《实时流计算服务用户指南》对等连接章节。

    如何设置安全组规则,请参见《虚拟私有云用户指南》“安全组”章节。

语法

语法格式

CREATE SINK STREAM stream_id (attr_name attr_type (',' attr_name attr_type)* )WITH (type = "dds",username = "",password = "",db_url = "",field_names = "");

语法说明

表1 语法说明

参数

是否必选

说明

type

输出通道类型,dds表示输出到文档数据库服务中。

username

数据库连接用户名。

password

数据库连接密码。

db_url

DDS实例的访问地址,形如:ip1:port,ip2:port/database/collection。

field_names

待插入数据字段的key,具体形式如:"f1,f2,f3",并且保证与sink中数据列一一对应。

batch_insert_data_num

表示一次性批量写入的数据量,值必须为正整数,默认值为10。

示例

将流qualified_cars 的数据输出到文档数据库collectionTest。

CREATE SINK STREAM qualified_cars (
car_id STRING,
car_owner STRING,
car_age INT,
average_speed INT,
total_miles INT
)
WITH (
type = "dds",
region = "cn-north-1" ,
db_url = "192.168.0.8:8635,192.168.0.130:8635/dbtest/collectionTest",
username = "xxxxxxxxxx",
password =  "xxxxxxxxxx",
field_names = "car_id,car_owner,car_age,average_speed,total_miles",
batch_insert_data_num = "10"
);
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!非常感谢您的反馈,我们会继续努力做到更好!
反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问