步骤三：添加自定义域名 1. 登录函数计算控制台，在最左的菜单栏中选择高级功能 > 域名管理。 2. 点击创建域名按钮，根据指引填写各种配置项。 3. 在路由设置 >路由配置中，点击添加路由信息。 配置项 子配置项 操作 域名 必填。填写自定义域名地址。例如（mytest.domain.com）。 公网/内网CNAME 同一个主账号相同，是作为您域名CNAME记录的值。 描述 用户针对该自定义域名的备注。 路由设置 路由设置 路由配置 设置域名路径与函数的对应关系，可以实现不同的请求路径触发不同的函数响应。可以根据需求，添加多条路径。 路由设置 路径 请求路径，区分大小写，只支持末尾的通配符，如：/mypath/。 路由设置 函数名称 当前请求路径触发的函数。 路由设置 版本或别名 触发函数的版本或别名。 路由设置 开启JWT校验 是否针对该条路由开启jwt校验。 HTTPS设置 HTTPS设置 HTTPS 根据需要启用或禁用HTTPS协议： 禁用：仅能通过http协议访问。 启用：同时支持http和https协议访问。 启用，且勾选强制https：仅支持https协议访问，通过http访问会重定向至https。 HTTPS设置 证书名称 SSL证书名称。 HTTPS设置 PEM证书 PEM证书内容。可以直接粘贴到输入框，也能通过文件上传。 HTTPS设置 PEM证书密钥 PEM证书密钥。可以直接粘贴到输入框，也能通过文件上传。 认证设置 认证设置 认证方式 无需认证：不需要对HTTP请求进行身份验证，支持匿名访问，任何人都可以发起HTTP请求调用您的函数。 JWT认证：需要对HTTP请求进行JWT认证。

本页对分布式融合数据库HTAP和 MySQL 二者之间的语法、功能特性上做出详细的对比。 分布式融合数据库HTAP高度兼容 MySQL 5.7 的网络协议、SQL功能及语法，以及生态工具（如PHPMyAdmin、Navicat、MySQL Workbench、mysqldump、Mydumper/Myloader）。MySQL 5.7 的客户端等均适用于分布式融合数据库HTAP。下面介绍分布式融合数据库HTAP与 MySQL 兼容性对比。 不支持的功能特性 存储过程与函数 触发器 事件 自定义函数 外键约束 全文语法与索引 空间类型的函数（即 GIS/GEOMETRY）、数据类型和索引 非 ascii、latin1、binary、utf8、utf8mb4、gbk 的字符集 SYS schema MySQL 追踪优化器 XML 函数 XProtocol 列级权限 XA 语法 CREATE TABLE tblName AS SELECT stmt 语法 CHECK TABLE 语法 CHECKSUM TABLE 语法 REPAIR TABLE 语法 OPTIMIZE TABLE 语法 HANDLER 语句 CREATE TABLESPACE 语句 MySQL 复制协议 有差异的功能特性 自增 ID 自增列既能保证唯一，也能保证在单个计算节点中自增，使用 AUTOINCREMENT MySQL兼容模式能保证多个计算节点中自增ID，但不保证自动分配的值的连续性。建议避免将缺省值和自定义值混用，以免出现 Duplicated Error 的错误信息。 可通过系统变量开启或者关闭允许移除列的 AUTOINCREMENT 属性。删除列属性的语法是：ALTER TABLE MODIFY 或 ALTER TABLE CHANGE。 不支持添加列的 AUTOINCREMENT 属性，移除该属性后不可恢复。

多样化接入方式 支持PC用户、手机用户、各种客户端用户就近接入边缘网络。 极致的加速效果 多协议加速：基于TCP/UDP四层加速。 智能选路：实时探测，最优路径回源。 优质传输：自研传输优化、链路优化。 高可用性：丰富的负载均衡及源站灾备策略。 安全可靠的传输 内容安全：业务透明转发，安全传输。 访问安全：丰富的访问控制策略，限制非法用户访问。 安全防护：内置DDoS防护，提供高阶攻击防护。 开发者平台 随着互联网业务的发展，动态请求（例如搜索结果、个性化推荐等）的占比越来越大，这类多元化内容需要经过计算后再返回给用户。 AOne开发者平台提供边缘函数、边缘KV存储，当控制台上的标准配置无法满足您的业务需求时，可以尝试使用边缘函数快速编程实现。 通过JavaScript ES6标准语法和模板，积木式地组合出个性化的边缘定制配置。在边缘节点进行计算，避免源站请求过载，从而减少源站并发和请求，使业务运行更加平滑，波动降低，同时还能降低带宽成本。 全球部署，超低延迟 AOne开发者平台将计算从源站前置到边缘节点上，缩短物理链路耗时50%以上，就近处理客户端请求，显著降低客户端请求的响应时间，让用户获得低延迟的计算体验。

本文介绍如何使用Python请求处理程序响应接收到的事件并执行相应的业务逻辑。 请求处理程序 请求处理程序 是您提供的一个方法。当您的函数被调用时，函数计算会运行该方法处理请求。 您可以通过函数计算控制台页面 配置请求处理程序 ，对于Python语言的函数，请求处理程序需配置为 [文件名].[方法名]。例如，您的文件名为index.py，方法名为handler，则请求处理程序可配置为 index.handler。 事件请求处理程序的方法签名定义如下： def handler(event, context): return 'Hello Python!' 方法名 您可以自定义方法名称。 event入参 您调用函数时传入的参数。 context入参 context参数中包含一些函数的运行时信息（例如RequestId、临时AccessKey等）。 HTTP请求处理程序的方法签名定义如下： coding: utf8 HELLOWORLD b'Hello world!n' def handler(environ, startresponse): status '200 OK' responseheaders [('Contenttype', 'text/plain')] startresponse(status, responseheaders) return [HELLOWORLD] 方法名 您可以自定义方法名称。 environ入参 用于存放所有HTTP请求的信息。 startresponse入参 发送 HTTP 响应的函数，包含两个参数：HTTP状态码、一组Python list对象组成的HTTP Headers。 示例：获取JSON中的字段 coding: utf8 import json def handler(event, context): person json.loads(event) name person["name"] address person["address"] return f"Input name is: {name}, address is: {address}" 示例二：使用HTTP触发器调用函数 import json import logging 配置日志 logger logging.getLogger() logger.setLevel(logging.INFO) def handler(environ, startresponse): 获取请求路径、URI和客户端IP requestpath environ.get('FCREQUESTPATH', '') requesturi environ.get('FCREQUESTURI', '') requestclientip environ.get('FCREQUESTCLIENTIP', '') 记录日志 logger.info("hello") print("print hello") 获取请求体数据 try: 读取请求体 requestbodysize int(environ.get('CONTENTLENGTH', 0)) except (ValueError): requestbodysize 0 requestbody environ['wsgi.input'].read(requestbodysize) 解析JSON请求体 try: if requestbody: jsondata json.loads(requestbody.decode('utf8')) logger.info(f"body: {json.dumps(jsondata)}") else: jsondata {} logger.info("body: empty") except json.JSONDecodeError as e: logger.error(f"JSON解析错误: {e}") jsondata {} 构建响应内容 responsecontent f"Path: {requestpath}nUri: {requesturi}nIP: {requestclientip}n" 设置响应状态和头部 status '200 OK' responseheaders [ ('header1', 'value1'), ('header2', 'value2'), ('ContentType', 'text/plain') ] startresponse(status, responseheaders) 返回响应内容 return [responsecontent.encode('utf8')]

Action属性 定义操作状态的具体行为，支持调用函数或服务API： 字段 类型 是否必选 描述 示例值 functionRef FunctionRef 是 引用具体的函数或操作，详见FunctionRef定义。 retryRef RetryRef 是 引用具体的重试策略，参考错误处理章节。 catchRef CatchRef 是 引用具体的错误捕获策略，参考错误处理章节。 actionExecuteMode string 否 执行模式，详细说明请参考服务集成模式，仅标准工作流下可配置。默认为RequestComplete。 RequestComplete WaitForTaskToken WaitForSystemCallback FunctionRef属性 定义操作状态的具体行为，支持调用函数或服务API： 字段 类型 是否必选 描述 示例值 type string 是 类型 CF:invokeFunction arguments map[string]any 否 调用参数，具体内容依动作类型而定。 调用示例 示例1：调用函数计算 通过操作状态调用函数计算服务，Parameters字段定义调用参数，具体规范参考配置参数文档。支持优化集成调用或直接使用天翼云OpenAPI。 plaintext specVersion: '0.8' version: '1.0' name: test start: InvokeFunction states: name: InvokeFunction type: Operation actions: functionRef: type: CF:invokeFunction arguments: functionName: testfunction qualifier: LATEST region: b342b77ef26b11ecb0ac0242ac110002 transition: nextState: Final

服务后缀 服务说明 zos dns msgc crs apm lts faas gts 全局事务：该服务由天翼云全局事务服务提供，全局事务服务是一款专为实现分布式环境下高性能事务一致性而设计的服务工具。它可以与MySQL、PostgreSQL等数据源，以及Spring Cloud、Dubbo等RPC框架和消息队列等中间件产品配合混合使用，以支持用户各种分布式数据库事务、多库事务、消息事务和服务链路级事务的组合需要 prome 应用性能监控：Prometheus监控为云上托管Prometheus服务，可为您的容器集群提供多种开箱即用的预置监控大盘与监控规则，实现免搭建的高效运维场景。 ags Agent沙箱：Agent 沙箱提供安全、弹性、可扩展的云端沙箱运行环境。在使用Agent沙箱产品时，通过连接该终端节点服务，可实现在内网调用沙箱服务。

套餐超出资费说明 如果套餐内用量用尽，高级版支持按需付费，免费版不支持。如果请求数较多，请直接订购高级版。相关资费见下表： 计费方式 说明 生效区域 规格 费用（元/百万次） 函数请求数按需 您业务实际请求数超过了套餐用量，可开通按需。 中国内地 10ms 1 函数请求数按需 您业务实际请求数超过了套餐用量，可开通按需。 中国内地 50ms 3 函数请求数按需 您业务实际请求数超过了套餐用量，可开通按需。 中国内地 100ms 5 计费示例 定价示例：网站请求个性化定制 您在CDN加速的域名，需要针对请求响应进行个性化定制。 假设您每月试用的函数请求数为2601百万次，且您的终端用户都在中国内地。 推荐订购开发者平台高级版套餐，其中高级版套餐包含100万次函数请求数。按照您的使用量，请求数将会超过100万次，超出套餐的请求数会自动按照按需计费。 计费项目 用量 费用计算（元/月） 每月总费用（元/月） 开发者平台高级版套餐 高级版套餐包含100万次函数请求数（支持10ms/50ms/100ms） 40 40 50ms规格的函数请求数超量 2600百万次 326007800 7800 总计 7840

图解：DeepSeek与公有云深度融合 从基础设施到智能中枢：DeepSeek如何重塑公有云服务价值链 高性能GPU云主机助力DeepSeek深度应用 天翼云SDWAN与DeepSeek超强联动，开启云上高效互联新时代 实践指南：DeepSeek驱动高效能云生态 GPU云主机/弹性云主机：零基础搭建DeepSeek云端环境指南 GPU物理机：物理机搭建DeepSeek指南 SDWAN跨境：SDWAN助力DeepSeek模型定向加速 智算容器：云容器引擎与DeepSeek融合实践 函数计算：天翼云函数计算与DeepSeek大模型 Q&A：典型问题解析与策略应对 常见问题解答

图解：DeepSeek与公有云深度融合 从基础设施到智能中枢：DeepSeek如何重塑公有云服务价值链 高性能GPU云主机助力DeepSeek深度应用 天翼云SDWAN与DeepSeek超强联动，开启云上高效互联新时代 实践指南：DeepSeek驱动高效能云生态 GPU云主机/弹性云主机：零基础搭建DeepSeek云端环境指南 GPU物理机：物理机搭建DeepSeek指南 SDWAN跨境：SDWAN助力DeepSeek模型定向加速 智算容器：云容器引擎与DeepSeek融合实践 函数计算：天翼云函数计算与DeepSeek大模型 Q&A：典型问题解析与策略应对 常见问题解答

本章节主要介绍如何通过Ranger进行UDF管控。 在大数据平台中，UDF常用于扩展SQL的表达能力，例如字符串处理、脱敏转换、时间计算等。但如果缺少统一的权限管控，部分高风险UDF可能被滥用，进而带来数据泄露、越权访问或不符合规范的计算行为。因此，需要通过Ranger对UDF的访问进行统一治理，实现对函数使用范围的精细化控制。 操作步骤 1、登录Ranger的WebUI界面。 2、点击Hadoop SQL下的Hive页签，您可以对Hive UDF进行权限管控： 1）点击右上角的“Add New Policy”添加新策略。 2）Ranger Hive可以配置UDF权限，例如配置一个用户是否可以使用、创建UDF，具体配置见下图。 具体参数说明如下： 参数名称 描述 Policy Name 策略名称，可自定义，不能与本服务内其他策略名称重复。 Policy Label 为当前策略指定一个标签，您可以根据这些标签搜索报告和筛选策略。 database 将适用该策略的列Hive数据库名称。 udf 指定UDF的名称。 Description 策略描述信息。 Audit Logging 是否审计此策略。 Allow Conditions 策略允许条件，配置本策略内允许的权限及例外。 如需添加多条权限控制规则，可单击+按钮添加。 如需当前条件中的用户或用户组管理本条策略，可勾选“Delegate Admin”，这些用户将成为受委托的管理员。被委托的管理员可以更新、删除本策略，它还可以基于原始策略创建子策略。 Deny Conditions 策略拒绝条件，配置本策略内拒绝的权限及例外，配置方法与“Allow Conditions”类似。 3）如果该函数由 Hive 注册，且函数类型为 UDAF，则在 Ranger 配置 Policy 时需要特别注意 Database 字段的填写方式。此类函数的库名前需要补充前缀 @。例如，若函数的限定名称为 testdb.testfunction，则在 Policy 配置页面中，Database 应填写为 @testdb。

RabbitMQ触发器可以订阅分布式消息服务RabbitMQ并根据消息触发关联的函数，借此能力，使得函数可以消费指定Queue的消息，执行自定义处理逻辑。 前提条件 已创建函数。 已创建RabbitMQ实例 操作步骤 1. 登录函数计算控制台，点击目标函数，进入函数详情。 2. 选择详情下顶部的配置选项卡。 3. 在配置选项卡中，选择左边的触发器选项卡。 4. 点击创建触发器 ，在弹出的右抽屉中选择RabbitMQ触发器，配置参数解释如下: 配置项 操作 示例 触发器类型 选择RabbitMQ触发器。 RabbitMQ触发器 名称 填写自定义的触发器名称。 rabbitmqtrigger 版本或别名 默认值为LATEST，支持选择任意函数版本或函数别名。 LATEST RabbitMQ实例 选择已创建的RabbitMQ实例。 Vhost 选择订阅的目标虚拟主机。 / Queue 选择订阅的目标队列。 myqueue 调用方法 选择函数调用方式。 同步调用 ：指触发器消费消息后投递到函数是同步调用，会等待函数响应后继续下一个消息投递。 异步调用：指触发器消费消息后投递到函数是异步调用，不会等待函数响应，可以快速消费事件。 User name 访问分布式消息服务RabbitMQ 版服务端时，需要传入用户名和密码进行权限认证，认证通过才允许访问服务端。 Password 访问分布式消息服务RabbitMQ 版服务端时，需要传入用户名和密码进行权限认证，认证通过才允许访问服务端。 触发器启用状态 创建触发器后是否立即启用。默认选择开启，即创建触发器后立即启用触发器。 启用 推送配置 批量推送条数：批量推送的最大值，积压值达到后立刻推送，取值范围为 [1, 10000]。 批量推送间隔：批量推送的最大时间间隔，达到后立刻推送，单位秒，取值[0,15]。默认0无需等待，数据直接推送。 推送格式：函数收到的事件格式，详情请查阅触发器事件消息格式。 重试策略 消息推送函数失败后重试的策略，共两种： 指数退避：指数退避重试，重试5次，重试周期为2，4，8，16，32（秒）。 线性退避：线性退避重试，重试5次，重试周期为1，2，3，4，5（秒）。 容错策略 当重试次数耗尽后仍然失败时的处理方式： 允许容错：当异常发生并超过重试策略配置时直接丢弃。 禁止容错：当异常发生并超过重试策略配置时继续阻塞执行。 死信队列 当容错策略为：允许容错时，可以额外开启死信队列。当开启死信队列时且异常发生并超过重试策略配置时，消息会被投递到指定的消息队列里，当前只支持投递到kafka和rocketmq 注意 请确保使用的用户名已经对选择的虚拟主机授权。

函数计算提供了丰富类型的触发器，不同种类的触发器事件格式会根据具体情况而有所差异，下面将详细列举各触发器对应的事件格式。 说明 本文提及的”事件格式“指事件函数中，接收到的event变量的数据结构。 HTTP触发器 通过HTTP触发器和自定义域名访问事件函数时，仅会把请求中的body部分通过event传递到事件函数的handler，数据类型是byte数组。而header和queryparams等其余请求信息会被丢弃，如果用户需要关心请求中除body以外的信息，可以使用Http函数 说明 ”事件函数“指的是标准运行时下，处理程序类型为”处理事件请求“的函数。 ”HTTP函数“指的是标准运行时下，处理程序类型为”处理 HTTP 请求“的函数。 云原生网关触发器 云原生网关触发器与Http触发器的行为相同，详细请参考上文。 定时触发器 plaintext { "time": "20241205T02:24:09Z", "name": "triggername", "data": "hello,trigger" } 参数 类型 示例值 描述 time string 20241205T02:24:09Z 消息被触发的时间。 name string triggername 触发器的名称。 data string hello，trigger 定时触发器配置中用户填写的”触发消息“内容。 Kafka触发器 有两种消息格式：RawData和CloudEvent格式，可在触发器配置里选择。 CloudEvent格式如下： plaintext [ { "id": "eca534636baf4d568f86cbdb748208ed", "source": "ctyun.faas.trigger.kafka", "specversion": "1.0", "type": "kafka:topic:sendmessage", "datacontenttype": "application/json", "subject": "kafkatriggermqbjvsezbpdialtest:testforfaas", "time": "20250522T02:04:16Z", "data": { "headers": {}, "timestamp": 1747879456, "topic": "testforfaas", "partition": 0, "offset": 15280, "key": "", "value": "msg[9]: 154b2a0e2c3d4b03ae9ec225b5370c3b, ts20250522 02:04:16" } } ] 参数 类型 示例值 描述 id string eca534636baf4d568f86cbdb748208ed 事件ID。标识事件的唯一值。 source string ctyun.faas.trigger.kafka 事件源。Kafka触发器固定为ctyun.faas.trigger.kafka。 specversion string 1.0 CloudEvents协议版本。 type string kafka:topic:sendmessage 事件类型。 datacontenttype string application/json 参数data的内容形式。 subject string kafkatriggermqbjvsezbpdialtest:testforfaas 事件主体。格式为[SourceName]:[消息topic]。 time string 20250522T02:04:16Z 消息被触发的时间。 data object Kafka触发器独有消息格式，详细参见下文RawData描述。

本章节主要介绍SQL查询优秀的最佳实践。 根据数据库的SQL执行机制以及大量的实践总结发现：通过一定的规则调整SQL语句，在保证结果正确的基础上，能够提高SQL执行效率。 使用union all代替union union在合并两个集合时会执行去重操作，而union all则直接将两个结果集合并、不执行去重。执行去重会消耗大量的时间，因此，在一些实际应用场景中，如果通过业务逻辑已确认两个集合不存在重叠，可用union all替代union以便提升性能。 join列增加非空过滤条件 若join列上的NULL值较多，则可以加上is not null过滤条件，以实现数据的提前过滤，提高join效率。 not in转not exists not in语句需要使用nestloop anti join来实现，而not exists则可以通过hash anti join来实现。在join列不存在null值的情况下，not exists和not in等价。因此在确保没有null值时，可以通过将not in转换为not exists，通过生成hash join来提升查询效率。 如下所示，如果t2.d2字段中没有null值(t2.d2字段在表定义中not null)查询可以修改为 SELECT FROM t1 WHERE NOT EXISTS (SELECT FROM t2 WHERE t1.c1t2.d2); 产生的计划如下： not exists执行计划 选择hashagg 。 查询中GROUP BY语句如果生成了groupagg+sort的plan性能会比较差，可以通过加大workmem的方法生成hashagg的plan，因为不用排序而提高性能。 尝试将函数替换为case语句。 DWS函数调用性能较低，如果出现过多的函数调用导致性能下降很多，可以根据情况把可下推函数的函数改成CASE表达式。 避免对索引使用函数或表达式运算。 对索引使用函数或表达式运算会停止使用索引转而执行全表扫描。 尽量避免在where 子句中使用! 或<> 操作符、null值判断、or连接、参数隐式转换。 对复杂SQL语句进行拆分。 对于过于复杂并且不易通过以上方法调整性能的SQL可以考虑拆分的方法，把SQL中某一部分拆分成独立的SQL并把执行结果存入临时表，拆分常见的场景包括但不限于： −作业中多个SQL有同样的子查询，并且子查询数据量较大。 −Plan cost计算不准，导致子查询hash bucket太小，比如实际数据1000W行，hash bucket只有1000。 −函数（如substr,tonumber）导致大数据量子查询选择度计算不准。 −多DN环境下对大表做broadcast的子查询。 其他更多调优点，请参考《开发指南》中的“典型SQL调优点”。

云原生网关触发器 云原生网关触发器能够让您网关的流量转向云工作流，能够支持更丰富的请求配置，如请求方法、请求头、请求参数等 前提条件 已创建工作流。 已创建云原生网关。 已创建函数计算服务的终端节点（VPCE）。 创建步骤请查看创建VPCE，其中”虚拟私有云“选择云原生网关所属的VPC，”服务“选择函数计算服务cn.ctyun.cnhuadong1.faas 函数计算服务在各资源池的名称（cn.ctyun.cnhuadong1.faas ）可能有差别，选择后缀为faas的即可，上述示例是在华东一资源池的名称 触发消息格式 通过云原生网关请求访问工作流时，仅会把请求中的body部分作为工作流的输入，数据类型必须为JSON格式。而header和queryparams等其余请求信息会被丢弃。 操作步骤 1. 登录工作流控制台，点击目标工作流，进入工作流详情详情。 2. 在配置选项卡中，选择左边的 工作流调度 选项卡。 3. 点击 创建工作流调度 ，在弹出的右抽屉中选择 云原生网关触发器，配置参数解释如下表。 配置项 操作说明 示例 触发器类型 选择云原生触发器。 云原生触发器 名称 填写自定义的触发器名称。 cgwtrigger 网关实例 选择已创建的云原生网关实例。 域名 选择网关实例已关联的域名。 mydomain.com 匹配路径 匹配请求的path（不含query参数），当前支持前缀匹配和精确匹配。末尾使用''代表使用前缀匹配。 /my/path 请求方法 匹配请求中的HTTP方法，可多选，不选则匹配所有HTTP方法 优先级 当多个路由同时匹配一个请求时，路径匹配深度较大的路由优先；路径匹配相同的情况下，路由优先级高（数字大）的优先匹配。 0 请求头 匹配请求中的HTTP header。 请求参数 匹配请求中的HTTP query参数。 触发器启用状态 创建触发器后是否立即启用。默认选择开启，即创建触发器后立即启用触发器。 启用

本章节为您介绍DWS的主要功能。 企业级数据仓库和标准SQL的支持 当创建好DWS 集群后，用户就可以使用SQL客户端工具连接集群，然后执行创建数据库、管理数据库、导入/导出数据以及查询数据的操作。 DWS 为用户提供了PB（petabyte）级高性能数据库，主要体现在： MPP大规模并行处理框架，支持行列混存、向量化执行，实现万亿数据关联分析秒级响应。 内存计算，基于Bloom Filter的Hash Join优化，性能提升2~10倍。 基于电信技术优化的大规模集群通信，提升计算节点间的传输效率。 基于代价的智能优化器，根据集群规模、数据量、生成最优计划，提高执行效率。 DWS 具有完备的SQL能力： 支持SQL 92、SQL 2003标准，支持存储过程，支持GBK和UTF8字符集，支持SQL标准函数与OLAP分析函数。 兼容PostgreSQL生态，与主流第三方数据库ETL，BI（business intelligence）工具厂商对接认证。 支持位图roaring bitmap数据类型及对应常见函数，在互联网、零售、教育、游戏等行业，提取用户特征、用户画像等场景有广泛应用。 在现有范围分区（Range Partitioning）基础上，新增支持list分区方式：PARTITION BY LIST (partitionkey,[...])，满足用户使用习惯。 HDFS/OBS外表READ ONLY外表支持JSON文件格式。 支持系统表赋权给普通用户，vacuum能够单独赋权，以及支持可扩展的预定义权限角色功能：新增表级权限Alter/Drop/Vacuum、新增Schema级权限Alter/Drop、新增预置角色rolesignalbackend、rolereadallstats。

本文介绍如何在Go运行环境下使用Go SDK、其它日志库提供的方法打印日志。 打印日志 当需要查看函数运行相关的自定义状态时，可以使用如下几种方式打印日志至标准输出stdout。往标准输出stdout打印的日志内容会被函数收集。 以下分别介绍所使用的几种日志打印方法。 使用context.GetLogger()方法打印日志 函数计算平台提供的Go SDK包含了 GetLogger()方法打印日志，使用该方法打印的每条日志中都包含日志级别、RequestId、时间、文件名和行号等信息。示例代码如下： package main import ( "context" "gitee.com/ctyunfaas/cfruntimegosdk/cf" "gitee.com/ctyunfaas/cfruntimegosdk/fccontext" ) func HandleRequest(ctx context.Context) (string, error) { fctx, : fccontext.FromContext(ctx) fctx.GetLogger().Info("Hello info") fctx.GetLogger().Infof("Hi, %sn", "info") fctx.GetLogger().Warn("Goodbye warn") fctx.GetLogger().Warnf("Byebye, %sn", "warn") return "hello world", nil } func main() { cf.Start(HandleRequest) } 函数被执行后，会输出以下日志： 20240311 18:46:00.102699 d0c5bc99e0a94d82beb02b23185640ea [INFO] main.go:12: Hello info 20240311 18:46:00.102715 d0c5bc99e0a94d82beb02b23185640ea [INFO] main.go:13: Hi, info 20240311 18:46:00.102725 d0c5bc99e0a94d82beb02b23185640ea [WARN] main.go:15: Goodbye warn 20240311 18:46:00.102729 d0c5bc99e0a94d82beb02b23185640ea [WARN] main.go:16: Byebye, warn

函数表达式 函数描述 ASCII() Return numeric value of leftmost character BIN() Return a string containing binary representation of a number BITLENGTH() Return length of argument in bits CHARLENGTH() Return number of characters in argument CHAR() Return the character for each integer passed CHARACTERLENGTH() Synonym for CHARLENGTH() CONCATWS() Return concatenate with separator CONCAT() Return concatenated string ELT() Return string at index number EXPORTSET() Return a string such that for every bit set in the value bits, you get an on string and for every unset bit, you get an off string FIELD() Return the index (position) of the first argument in the subsequent arguments FINDINSET() Return the index position of the first argument within the second argument FORMAT() Return a number formatted to specified number of decimal places HEX() Return a hexadecimal representation of a decimal or string value INSERT() Insert a substring at the specified position up to the specified number of characters INSTR() Return the index of the first occurrence of substring LCASE() Synonym for LOWER() LEFT() Return the leftmost number of characters as specifified QUOTE() Escape the argument for use in an SQL statement NOT REGEXP Negation of REGEXP NOT LIKE Negation of simple pattern matching LTRIM() Remove leading spaces REPEAT() Repeat a string the specifified number of times REPLACE() Replace occurrences of a specifified string MAKESET() Return a set of commaseparated strings that have the corresponding bit in bits set OCT() Return a string containing octal representation of a number MID() Return a substring starting from the specifified position ORD() Return character code for leftmost character of the argument LOWER() Return the argument in lowercase LENGTH() Return the length of a string in bytes LOCATE() Return the position of the fifirst occurrence of substring LPAD() Return the string argument, leftpadded with the specifified string REVERSE() Reverse the characters in a string LIKE Simple pattern matching OCTETLENGTH() Synonym for LENGTH() POSITION() Synonym for LOCATE() RIGHT() Return the specifified rightmost number of characters RPAD() Append string the specifified number of times STRCMP() Compare two strings UPPER() Convert to uppercase TRIM() Remove leading and trailing spaces RTRIM() Remove trailing spaces UNHEX() Return a string containing hex representation of a number SPACE() Return a string of the specifified number of spaces SUBSTRINGINDEX() Return a substring from a string before the specifified number of occurrences of the delimiter SUBSTR() Return the substring as specifified SUBSTRING() Return the substring as specifified UCASE() Synonym for UPPER()

可信云服务可以通过IAM委托的方式访问其他云服务的资源。可信实体为天翼云服务的IAM委托，包括普通云服务委托和云服务关联委托。本文介绍事件总线EventBridge的服务内联委托。 什么是服务内联委托 在某些场景下，事件总线EventBridge为了完成自身的某个功能，需要获取其他云服务的访问权限，因此，事件总线EventBridge创建了与云服务内联委托，即服务内联委托CtyunAssumeRoleForEventBridge。 使用事件总线EventBridge，系统提供的服务内联委托及其包含的系统权限策略如下： 服务内联委托：CtyunAssumeRoleForEventBridge 系统权限策略：CtyunAssumePolicyForEventBridge CtyunAssumeRoleForEventBridge 服务内联委托CtyunAssumeRoleForEventBridge具有获取访函数列表、函数详情以及调用函数的权限；具有对分布式消息服务Kafka、分布式消息服务RocketMQ、分布式消息服务MQTT与分布式消息服务RabbitMQ的管理员权限；具有专有网络VPC、VPCE的管理员权限。 服务内联委托CtyunAssumeRoleForEventBridge被授予权限策略CtyunAssumePolicyForEventBridge，该权限策略的内容如下： plaintext { "Version": "1.1", "Statement": [ { "Action": [ "cf:inst:InvokeFunction", "cf:inst:GetFunction", "cf:inst:ListFunctions", "KAFKA::", "MQ2::", "mqtt::", "AMQP::", "vpce::", "vpc::" ], "Resource": [ "" ], "Effect": "Allow" } ] } 以下是使用事件总线EventBridge时，需要使用服务内联委托的场景： 建立函数计算规则时，需要委托事件总线EventBridge具有获取访函数列表、函数详情以及调用函数的权限。 建立消息中间件事件源与事件目标时，需要委托事件总线EventBridge具有对分布式消息服务Kafka、分布式消息服务RocketMQ、分布式消息服务MQTT与分布式消息服务RabbitMQ的管理员权限。 建立网络端点时，需要委托事件总线EventBridge具有专有网络VPC、VPCE的管理员权限。

本章节介绍云原生API网关产品特性。 API网关 API网关同时具备传统的流量网关和业务网关功能，提供全局性和独立业务域级别的流量管理策略，支持Nacos、K8s和函数计算等多种服务发现方式，支持TLS加密通信和多种身份认证方式，构筑安全的流量入口。 功能集 功能 功能详情 实例管理 实例管理 支持网关实例的订购、查看、退订、版本升级、升降配操作 实例管理 接入点管理 支持关联ELB，实现网关公网访问以及入站负载均衡 实例管理 策略管理 支持实例级绑定IP黑白名单、自定义响应等策略 实例管理 可观测 支持实例级监控分析 API管理 API生命周期管理 支持API在线设计、调试、发布、下线等生命周期管理 API管理 多版本管理 支持多版本共存 API管理 快照管理 支持发布历史查看、在线版本切换等功能 API管理 策略管理 支持API绑定限流、跨域、重写、认证、熔断等多种策略 API管理 可观测 支持API级监控分析 路由管理 匹配管理 支持请求路径、请求头、请求方法、请求参数、Cookie等匹配条件 路由管理 策略管理 支持路由绑定限流、跨域、重写、认证、熔断等多种策略 路由管理 可观测 支持路由级监控分析 服务来源与服务管理 容器服务 支持从CCE发现并导入服务 服务来源与服务管理 注册配置中心 支持从Nacos和Eureka发现并导入服务 服务来源与服务管理 函数计算 支持从函数计算发现并导入服务 服务来源与服务管理 固定地址/域名 指定IP地址或域名作为上游服务 域名管理 域名管理 支持域名管理，支持HTTP、HTTPS协议 域名管理 证书管理 支持证书管理 插件市场 插件管理 支持插件安装、卸载 插件市场 插件配置管理 支持插件配置启用、停用、绑定、解绑 插件市场 插件分类 丰富的插件分类，传输协议、安全防护、认证鉴权、流量管控等多种插件扩展支持 消费者管理 消费者管理 支持消费者新增、编辑、删除、启用、停用等 消费者管理 消费者授权 支持消费者授权、解除授权，支持实例级、API级、路由级多维授权范围

事件目标是事件规则的一部分，负责消费经事件规则过滤与转换后的事件。 事件目标 事件总线EventBridge支持以下事件目标： 函数计算 分布式消息服务RocketMQ 分布式消息服务RabbitMQ 分布式消息服务Kafka HTTP、HTTPS地址

本章介绍函数工作流如何配置磁盘挂载。 概述 FuncitonGraph提供了文件系统挂载功能，多个函数可以通过共用一个文件系统，实现文件共享。相比于对单个函数实例分配的临时磁盘空间限制，可以极大扩展函数的执行和存储空间。 场景介绍 目前FunctionGraph函数支持以下文件系统配置。 SFS Turbo文件系统 SFS Turbo分为SFS Turbo标准型、SFS Turbo标准型增强版、SFS Turbo性能型和SFS Turbo性能型增强版。SFS Turbo为用户提供一个完全托管的共享文件存储，能够弹性伸缩至320TB规模，具备高可用性和持久性，为海量的小文件、低延迟高IOPS型应用提供有力支持。适用于多种应用场景，包括高性能网站、日志存储、压缩解压、DevOps、企业办公、容器应用等。 ECS共享目录 ECS共享目录是通过nfs服务，把ECS上的指定目录设置为共享文件系统，函数（和ECS相同的VPC配置）可以挂载对应目录进行读写等操作，实现计算资源的动态扩展。此类型适合业务不太频繁的场景。 使用文件系统挂载功能具有以下优势： 函数执行空间相比于/tmp，可以极大扩展存储空间。 多个函数之间可以共享访问已经配置好的文件系统。 ECS计算资源动态扩展，利用ECS已有的存储能力实现更大的计算能力。 说明 您可以在/tmp路径下写临时文件，最大不能超过512MB。 创建委托 为函数添加文件系统配置需要先给函数设置相关服务的委托。 创建委托时，委托类型选择云服务，云服务选择FunctionGraph，因为委托数目有限，而且目前界面上不支持修改，建议可以创建一个权限较大的委托（Tenant Administrator），可以支持在函数中操作当前区域内的所有资源。

本页介绍天翼云TeleDB数据库Oracle语法中的日期函数。 NUMTODSINTERVAL numtodsinterval(,) x是一个数字、c是一个字符串，表明x的单位，这个函数把x转为interval day to second数据类型。 teledb select sysdate,sysdate+numtodsinterval(2,'hour') as res from dual; orclsysdate res + 20230824 10:49:53.417051 20230824 12:49:53.417051 (1 row) teledb DBTIMEZONE teledb select DBTIMEZONE from dual; dbtimezone 08:00:00 (1 row) teledb MONTHSBETWEEN teledb select monthsbetween(todate('20210331', 'yyyymmdd'), todate('20200131', 'yyyymmdd')) as months from dual; months 14 (1 row) teledb LASTDAY LASTDAY函数返回指定日期对应月份的最后一天。 teledb SELECT lastday('20200501') FROM dual; lastday 20200531 00:00:00+08 (1 row) teledb ADDMONTHS ADDMONTHS(x,y) x值为日期，y值为数量，用于计算某个日期向前或者向后y个月后的时间。 teledb select addmonths(sysdate,1) from dual; addmonths 20230924 11:08:17.194487 (1 row) teledb select addmonths(sysdate,1) from dual; addmonths 20230724 11:08:21.019573 (1 row) teledb

本页介绍天翼云TeleDB数据库Oracle语法中的日期函数。 NUMTODSINTERVAL numtodsinterval( , ) x是一个数字、c是一个字符串，表明x的单位，这个函数把x转为interval day to second数据类型。 plaintext teledb select sysdate,sysdate+numtodsinterval(2,'hour') as res from dual; orclsysdate res + 20230824 10:49:53.417051 20230824 12:49:53.417051 (1 row) teledb DBTIMEZONE plaintext teledb select DBTIMEZONE from dual; dbtimezone 08:00:00 (1 row) teledb MONTHSBETWEEN plaintext teledb select monthsbetween(todate('20210331', 'yyyymmdd'), todate('20200131', 'yyyymmdd')) as months from dual; months 14 (1 row) teledb LASTDAY LASTDAY函数返回指定日期对应月份的最后一天。 plaintext teledb SELECT lastday('20200501') FROM dual; lastday 20200531 00:00:00+08 (1 row) teledb ADDMONTHS ADDMONTHS(x,y) x值为日期，y值为数量，用于计算某个日期向前或者向后y个月后的时间。 plaintext teledb select addmonths(sysdate,1) from dual; addmonths 20230924 11:08:17.194487 (1 row) teledb select addmonths(sysdate,1) from dual; addmonths 20230724 11:08:21.019573 (1 row) teledb

本页介绍天翼云TeleDB数据库Oracle语法中的日期函数。 NUMTODSINTERVAL numtodsinterval( , ) x是一个数字、c是一个字符串，表明x的单位，这个函数把x转为interval day to second数据类型。 plaintext teledb select sysdate,sysdate+numtodsinterval(2,'hour') as res from dual; orclsysdate res + 20230824 10:49:53.417051 20230824 12:49:53.417051 (1 row) teledb DBTIMEZONE plaintext teledb select DBTIMEZONE from dual; dbtimezone 08:00:00 (1 row) teledb MONTHSBETWEEN plaintext teledb select monthsbetween(todate('20210331', 'yyyymmdd'), todate('20200131', 'yyyymmdd')) as months from dual; months 14 (1 row) teledb LASTDAY LASTDAY函数返回指定日期对应月份的最后一天。 plaintext teledb SELECT lastday('20200501') FROM dual; lastday 20200531 00:00:00+08 (1 row) teledb ADDMONTHS ADDMONTHS(x,y) x值为日期，y值为数量，用于计算某个日期向前或者向后y个月后的时间。 plaintext teledb select addmonths(sysdate,1) from dual; addmonths 20230924 11:08:17.194487 (1 row) teledb select addmonths(sysdate,1) from dual; addmonths 20230724 11:08:21.019573 (1 row) teledb

集成类型 集成的服务名称 请求响应（RequestComplete） 等待系统回调（WaitForSystemCallback） 等待任务令牌（WaitForTaskToken） 优化集成 函数计算 yes no yes 优化集成 云工作流（CloudFlow） yes yes yes 优化集成 消息服务robotmsg yes no yes 优化集成 HTTP yes no yes 优化集成 对象存储 ZOS yes no no 普通集成 所有天翼云产品OpenAPI yes no no

本页介绍天翼云TeleDB数据库Oracle语法中的日期函数。 NUMTODSINTERVAL numtodsinterval( , ) x是一个数字、c是一个字符串，表明x的单位，这个函数把x转为interval day to second数据类型。 plaintext teledb select sysdate,sysdate+numtodsinterval(2,'hour') as res from dual; orclsysdate res + 20230824 10:49:53.417051 20230824 12:49:53.417051 (1 row) teledb DBTIMEZONE plaintext teledb select DBTIMEZONE from dual; dbtimezone 08:00:00 (1 row) teledb MONTHSBETWEEN plaintext teledb select monthsbetween(todate('20210331', 'yyyymmdd'), todate('20200131', 'yyyymmdd')) as months from dual; months 14 (1 row) teledb LASTDAY LASTDAY函数返回指定日期对应月份的最后一天。 plaintext teledb SELECT lastday('20200501') FROM dual; lastday 20200531 00:00:00+08 (1 row) teledb ADDMONTHS ADDMONTHS(x,y) x值为日期，y值为数量，用于计算某个日期向前或者向后y个月后的时间。 plaintext teledb select addmonths(sysdate,1) from dual; addmonths 20230924 11:08:17.194487 (1 row) teledb select addmonths(sysdate,1) from dual; addmonths 20230724 11:08:21.019573 (1 row) teledb

本页介绍天翼云TeleDB数据库Oracle语法中的日期函数。 NUMTODSINTERVAL numtodsinterval( , ) x是一个数字、c是一个字符串，表明x的单位，这个函数把x转为interval day to second数据类型。 plaintext teledb select sysdate,sysdate+numtodsinterval(2,'hour') as res from dual; orclsysdate res + 20230824 10:49:53.417051 20230824 12:49:53.417051 (1 row) teledb DBTIMEZONE plaintext teledb select DBTIMEZONE from dual; dbtimezone 08:00:00 (1 row) teledb MONTHSBETWEEN plaintext teledb select monthsbetween(todate('20210331', 'yyyymmdd'), todate('20200131', 'yyyymmdd')) as months from dual; months 14 (1 row) teledb LASTDAY LASTDAY函数返回指定日期对应月份的最后一天。 plaintext teledb SELECT lastday('20200501') FROM dual; lastday 20200531 00:00:00+08 (1 row) teledb ADDMONTHS ADDMONTHS(x,y) x值为日期，y值为数量，用于计算某个日期向前或者向后y个月后的时间。 plaintext teledb select addmonths(sysdate,1) from dual; addmonths 20230924 11:08:17.194487 (1 row) teledb select addmonths(sysdate,1) from dual; addmonths 20230724 11:08:21.019573 (1 row) teledb

本页介绍天翼云TeleDB数据库Oracle语法中的日期函数。 NUMTODSINTERVAL numtodsinterval( , ) x是一个数字、c是一个字符串，表明x的单位，这个函数把x转为interval day to second数据类型。 plaintext teledb select sysdate,sysdate+numtodsinterval(2,'hour') as res from dual; orclsysdate res + 20230824 10:49:53.417051 20230824 12:49:53.417051 (1 row) teledb DBTIMEZONE plaintext teledb select DBTIMEZONE from dual; dbtimezone 08:00:00 (1 row) teledb MONTHSBETWEEN plaintext teledb select monthsbetween(todate('20210331', 'yyyymmdd'), todate('20200131', 'yyyymmdd')) as months from dual; months 14 (1 row) teledb LASTDAY LASTDAY函数返回指定日期对应月份的最后一天。 plaintext teledb SELECT lastday('20200501') FROM dual; lastday 20200531 00:00:00+08 (1 row) teledb ADDMONTHS ADDMONTHS(x,y) x值为日期，y值为数量，用于计算某个日期向前或者向后y个月后的时间。 plaintext teledb select addmonths(sysdate,1) from dual; addmonths 20230924 11:08:17.194487 (1 row) teledb select addmonths(sysdate,1) from dual; addmonths 20230724 11:08:21.019573 (1 row) teledb

本章节主要介绍数据湖探索（DLI）的功能特性。 功能介绍 DLI用户可以通过可视化界面、Restful API、JDBC、Beeline等多种接入方式对云上RDS和DWS等异构数据源进行查询分析，数据格式兼容CSV、JSON、Parquet和ORC主流数据格式。 三大基本功能 SQL作业支持SQL查询功能：可为用户提供标准的SQL语句。 Flink作业支持Flink SQL在线分析功能：支持Window、Join等聚合函数、地理函数、CEP函数等，用SQL表达业务逻辑，简便快捷实现业务。 Spark作业提供全托管式Spark计算特性：用户可通过交互式会话(session)和批处理(batch)方式提交计算任务，在全托管Spark队列上进行数据分析。 多数据源分析 Spark跨源连接：可通过DLI访问DWS，RDS和CSS等数据源。 Flink跨源支持与多种云服务连通，形成丰富的流生态圈。数据湖探索的流生态分为云服务生态和开源生态： 云服务生态：数据湖探索在Flink SQL中支持与其他服务的连通。用户可以直接使用SQL从这些服务中读写数据。 开源生态：通过增强型跨源连接建立与其他VPC的网络连接后，用户可以在数据湖探索的租户独享队列中访问所有Flink和Spark支持的数据源与输出源，如Kafka、Hbase、ElasticSearch等。 存算分离 用户将数据存储到OBS后，DLI可以直接和OBS对接进行数据分析。存算分离的架构下，使得存储资源和计算资源可以分开申请和计费，降低了成本并提高了资源利用率。 存算分离场景下，DLI支持OBS在创建桶时数据冗余策略选择单AZ或者多AZ存储，两种存储策略区别如下： 选择多AZ存储，数据将冗余存储至多个AZ中，可靠性更高。选择多AZ存储的桶，数据将存储在同一区域的多个不同AZ。当某个AZ不可用时，仍然能够从其他AZ正常访问数据，适用于对可靠性要求较高的数据存储场景。建议优选使用多AZ存储的策略。 选择单AZ存储，数据仅存储在单个AZ中，但相比多AZ更加便宜。

本文介绍事件总线EventBridge产品中的典型应用场景。 场景一：函数计算触发器 事件总线提供了标准化与中心化的接入方式，支持天翼云应用及自定义应用作为事件源接入。 事件总线EventBridge对事件进行过滤，路由与转换，然后触发事件规则对应的函数，处理对应的业务逻辑。 场景二：多功能数据集成与同步 事件总线EventBridge的事件流模块适用于端到端、实时的过滤与转换流式数据。通过事件流，可轻松实现消息路由与消息同步。 场景三：应用间事件流转 应用产生的事件可以通过事件总线触发，实现应用间的流转，打破应用间的事件孤岛；事件总线EventBridge提供丰富的事件过滤与转换能力。

应用中心是一个集开发、部署、管理等全生命周期服务的平台,提供了Web开发、人工智能、音视频处理等丰富的Serverless应用模板。您可以一键部署预置的模板,也可以在此基础上进行二次开发以满足个性化需求。 产品优势 Serverless应用中心具有以下几点优势： 1. 从开发到运维一站式解决方案，提供快速上手、极简运维的使用体验，让您专注于具体的业务开发。 2. 支持Serverless Devs组件部署应用，您可以使用s.yaml编排业务，并一键部署到天翼云函数计算。 3. 丰富的应用模板，满足您不同编程语言或业务领域的个性化定制。 基本概念 应用模板 Serverless应用模板是一种预先设计好的具有基本功能的Serverless应用案例，允许开发者使用模板快速创建应用。 应用 Serverless应用是具体业务编排的整体资源的描述，一个应用包含Serverless函数以及函数所使用到的云服务资源、差异化部署管理的环境、部署执行的流水线。 环境 在Serverless应用中心领域，环境提供了灵活的应用差异化部署管理，您可以创建不同的环境，并为各个环境配置不同的部署资源、环境变量和流水线。 流水线 流水线提供了CI/CD能力，帮助您快速将应用源码进行编译构建，并发布到天翼云上。 产品计费 Serverless应用中心可以免费使用。但是，在部署应用时所涉及到的相关云产品服务可能会产生费用，具体的计费规则请参照相应云产品的计费说明。

本章节主要介绍 快速定位查询存储倾斜表的最佳实践。 目前提供的倾斜查询接口有函数：tabledistribution(schemaname text, tablename text) 、tabledistribution() 以及视图PGXCGETTABLESKEWNESS，客户可以根据自身业务情况来选择使用。 场景一：磁盘满后快速定位存储倾斜的表 首先，通过pgstatgetlastdatachangedtime(oid)函数查询出近期发生过数据变更的表，介于表的最后修改时间只在进行IUD操作的CN记录，要查询库内1天(间隔可在函数中调整)内被修改的所有表，可以使用如下封装函数： CREATE OR REPLACE FUNCTION getlastchangedtable(OUT schemaname text, OUT relname text) RETURNS setof record AS $$ DECLARE rowdata record; rowname record; querystr text; querystrnodes text; BEGIN querystrnodes : 'SELECT nodename FROM pgxcnode where nodetype ''C'''; FOR rowname IN EXECUTE(querystrnodes) LOOP querystr : 'EXECUTE DIRECT ON (' rowname.nodename ') ''SELECT b.nspname,a.relname FROM pgclass a INNER JOIN pgnamespace b on a.relnamespace b.oid where pgstatgetlastdatachangedtime(a.oid) BETWEEN currenttimestamp 1 AND currenttimestamp;'''; FOR rowdata IN EXECUTE(querystr) LOOP schemaname rowdata.nspname; relname rowdata.relname; return next; END LOOP; END LOOP; return; END; $$ LANGUAGE plpgsql; 然后，通过tabledistribution(schemaname text, tablename text)查询出表在各个DN占用的存储空间。 SELECT tabledistribution(schemaname,relname) FROM getlastchangedtable(); 场景二：常规数据倾斜巡检 在库中表个数少于1W的场景，直接使用倾斜视图查询当前库内所有表的数据倾斜情况。 SELECT FROM pgxcgettableskewness ORDER BY totalsize DESC; 在库中表个数非常多（至少大于1W）的场景，因PGXCGETTABLESKEWNESS涉及全库查并计算非常全面的倾斜字段，所以可能会花费比较长的时间（小时级），建议参考PGXCGETTABLESKEWNESS视图定义，直接使用tabledistribution()函数自定义输出，减少输出列进行计算优化，例如： SELECT schemaname,tablename,max(dnsize) AS maxsize, min(dnsize) AS minsize FROM pgcatalog.pgclass c INNER JOIN pgcatalog.pgnamespace n ON n.oid c.relnamespace INNER JOIN pgcatalog.tabledistribution() s ON s.schemaname n.nspname AND s.tablename c.relname INNER JOIN pgcatalog.pgxcclass x ON c.oid x.pcrelid AND x.pclocatortype 'H' GROUP BY schemaname,tablename;