一、注意事项
·该云函数目前只能将腾讯云 CKafka 作为数据源，暂不支持自建 Kafka。
·该云函数目前只能将腾讯云数据仓库 TCHouse-P 中的某一张表作为目标数据写入，如果有多张表的需求，请按照以下流程每张表创建对应的云函数。
二、步骤一：创建函数
1. 登录 云函数控制台，选择左侧导航中的函数服务。
2. 在函数服务页面，单击新建。
3. 在新建页面模糊搜索中搜索关键词“ckafka数据加载到CDW”，设置完成后单击下一步。
4. 进入函数配置页面后，配置参数请参见 创建函数，其中环境配置和网络配置，配置参数如下：
·环境配置
·内存：根据实际运行情况来设置，默认为128MB。当导入过程中出现内存不足的问题时，需调大内存。
·环境变量：
| 参数 | 必填 | 说明 |
| DB_DATABASE | 是 | 数据库名 |
| DB_HOST | 是 | 如果函数是私有网络，并且和腾讯云数据仓库 TCHouse-P 是在同一子网，则可以填写腾讯云数据仓库 TCHouse-P 的内网 IP，否则需要填写外网 IP，并配置白名单 |
| DB_USER | 是 | 用户名 |
| DB_PASSWORD | 是 | 用户密码 |
| DB_SCHEMA | 是 | 模式名，如果创建表的时候未指定，通常是 public |
| DB_TABLE | 是 | 表名 |
| DB_PORT | 否 | 腾讯云数据仓库 TCHouse-P 端口，默认为5436 |
| MSG_SEPARATOR_ASCII | 否 | CKafka 中数据分隔符的 ASCII 码，默认为39（逗号），由于逗号经常会出现在业务数据中，这里建议使用11（Vertical tab） |
| MSG_NULL | 否 | CKafka 中消费的 NULL 值，默认是 \\N |
| REPLACE_0X00 | 否 | 是否替换字符串中的0x00，默认是0（1表示替换） |
| ENABLE_DEBUG | 否 | 是否打印错误的记录，默认是0（1表示打印） |
| ENABLE_COS | 否 | 是否把未写入记录转储到 COS 上，默认是0（1表示转储） |
| COS_SECRET_ID | 否 | 访问 COS 的 secret_id，ENABLE_COS 如果为1，该字段必填 |
| COS_SECRET_KEY | 否 | 访问 COS 的 secret_key，ENABLE_COS 如果为1，该字段必填 |
| COS_BUCKET | 否 | COS 存储桶名称，ENABLE_COS 如果为1，该字段必填 |
| STATMENT_TIMEOUT | 否 | 查询超时时间，默认是50秒 |
·网络配置
·私有网络：建议启用私有网络，并将 VPC 和子网的值配置的与腾讯云数据仓库 TCHouse-P 相同。
下图为腾讯云数据仓库 TCHouse-P 对应的值。
·公网访问：建议同时启用公网访问。
5. 单击完成。
三、步骤二：配置触发器
1. 登录 云函数控制台，选择左侧导航中的函数服务。
2. 在函数服务页面，选择函数名，进入函数详情页面。
3. 选择左侧导航中的触发管理，单击创建触发器。
4. 在创建触发器页面，将触发方式设置为“Ckafka 触发”：
关于触发器参数配置可以参考 CKafka 触发器。
5. 单击提交。