检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
dws-client 简介 dws-client是一款基于DWS JDBC实现的高性能、便捷入库工具,用户在使用时必须保证JDBC可以连接。其中使用dws-client入库具备如下优势: dws-client提供对缓存的空间、时间维度的限制,支持攒批提升入库性能,以满足业务在高峰低谷期的入库实时性。
PGXC_COMM_CLIENT_INFO PGXC_COMM_CLIENT_INFO视图存储所有节点客户端连接信息(DN上查询该视图显示CN连接DN的信息)。 表1 PGXC_COMM_CLIENT_INFO字段 名称 类型 描述 node_name text 当前节点的名称。
PG_COMM_CLIENT_INFO PG_COMM_CLIENT_INFO视图存储单个节点客户端连接信息(DN上查询该视图显示CN连接DN的信息)。 表1 PG_COMM_CLIENT_INFO字段 名称 类型 描述 node_name text 当前节点的名称。 app text
DWS-Connector版本发布包含:dws-client、dws-connector-flink、dws-flink-ingestion组件,入库相关均使用dws-client作业底层入库组件,版本统一使用dws-client版本号; 当前版本分为1.x和2.x版本,1.x版
DWS-Connector DWS-Connector版本说明 dws-client dws-connector-flink
ON_VERSIONS PG_AVAILABLE_EXTENSIONS PG_BULKLOAD_STATISTICS PG_COMM_CLIENT_INFO PG_COMM_DELAY PG_COMM_STATUS PG_COMM_RECV_STREAM PG_COMM_SEND_STREAM
集群绑定EIP 功能介绍 该接口用于集群绑定EIP。 默认情况下,只有华为云账号用户或拥有Security Administrator权限的用户才具备查询委托和创建委托的权限。账号中的IAM用户,默认没有查询委托和创建委托的权限,在使用弹性IP绑定功能时页面会屏蔽绑定按钮,此时需联系有“DWS
PGXC_COMM_CLIENT_INFO PGXC_COMM_CLIENT_INFO视图存储所有节点客户端连接信息(DN上查询该视图显示CN连接DN的信息)。 表1 PGXC_COMM_CLIENT_INFO字段 名称 类型 描述 node_name text 当前节点的名称。
ON_VERSIONS PG_AVAILABLE_EXTENSIONS PG_BULKLOAD_STATISTICS PG_COMM_CLIENT_INFO PG_COMM_DELAY PG_COMM_STATUS PG_COMM_RECV_STREAM PG_COMM_SEND_STREAM
PG_COMM_CLIENT_INFO PG_COMM_CLIENT_INFO视图存储单个节点客户端连接信息(DN上查询该视图显示CN连接DN的信息)。 表1 PG_COMM_CLIENT_INFO字段 名称 类型 描述 node_name text 当前节点的名称。 app text
Developer、Instant Client和DSC,下载地址参见表1 表1 准备工具 工具名 描述 下载地址 PL/SQL Developer Oracle可视化开发工具 PL/SQL Developer下载地址 Oracle Instant Client Oracle客户端 Instant
JSONObject context, DwsInvokeFunction<T> invoke); config为dws-client的参数,跟使用dws-client一致。 context是为了便于在业务中使用缓存之类的操作提供的一个全局上下文,可在构建时指定,后续每次回调处理数据的接口便会附带此对象。
查看运维状态类 前提条件:正常连接上DWS集群。 查看当前业务整体运行情况。 1 select coorname, usename, client_addr, sysdate-query_start as duration, state, enqueue,waiting, pid
参数说明:控制写到服务器日志文件中的消息级别。每个级别都包含排在它后面的所有级别中的信息。级别越低,服务器运行日志中记录的消息就越少。 当client_min_messages和log_min_messages取值相同时,其值所代表的级别不同。 参数类型:SUSET 取值范围:枚举类
Flink SQL配置参数 Flink SQL中设置的PRIMARY KEY将自动映射到dws-client中的uniqueKeys。参数跟随client版本发布,参数功能与client一致,以下参数说明表示为最新参数。 表1 数据库配置 参数 说明 默认值 connector f
下载dws-client相关插件。 dws-kettle-plugin.jar:下载地址。 dws-client.jar:访问下载地址,获取最新版本使用。 caffeine.jar:访问下载地址,选择与dws-client对应依赖的版本,例如dws-client为1.0.10,则获取1
参数说明:控制写到服务器日志文件中的消息级别。每个级别都包含排在它后面的所有级别中的信息。级别越低,服务器运行日志中记录的消息就越少。 当client_min_messages和log_min_messages取值相同时,其值所代表的级别不同。 参数类型:SUSET 取值范围:枚举类
receive data from client: %m" SQLSTATE: XX000 错误原因:系统内部错误。 解决办法:请联系技术支持工程师提供技术支持。 GAUSS-02183: "incomplete message from client" SQLSTATE: 08P01
引入依赖 概述 dws-connector-flink是在dws-client的基础上对接Flink的一个工具,工具为对dws-client的包装,整体入库能力跟dws-client一致。dws-connector-flink为GaussDB(DWS)团队自研工具,后续将根据GaussDB(DWS)数据库持续优化。
数据库用户名。 application_name String 用户应用名称。 client_address String 客户端地址。 client_hostname String 客户端主机名。 client_port String 客户端用于与后台通讯的tcp端口号,如果使用unix套接字,则为-1。