tencent cloud

云函数

动态与公告
产品动态
产品公告
新手指引
产品简介
产品概述
相关概念
工作原理
产品优势
应用场景
相关产品
购买指南
计费概述
计费方式
计费项与计费方式
函数算力支持
免费额度
产品定价
计费示例
欠费与停服说明
快速入门
使用控制台创建一个事件函数
操作指南
配额管理
函数管理
Web 函数管理
日志管理
并发管理
触发器管理
函数 URL
自定义域名
版本管理
别名管理
权限管理
运行实例管理
插件管理
监控与告警管理
网络配置
层管理
执行配置
扩展存储管理
DNS 缓存配置
资源托管模式管理
近离线资源托管模式
工作流
触发器
触发器概述
触发器事件消息结构汇总
API 网关触发器
COS 触发器
CLS 触发器
定时触发器
CKafka 触发器
Apache Kafka 触发器
MQTT 触发器
触发器配置描述
MPS 触发器
CLB 触发器说明
云 API 触发器
开发指南
基本概念
测试云函数
环境变量
依赖安装
使用容器镜像
使用 Docker 安装依赖
错误类型与重试策略
死信队列
云函数接入数据库
自动化部署
云函数状态码
常见错误码解决方法
开发者工具
Serverless Web IDE
函数间调用 SDK
第三方工具
代码开发
Python
Node.js
Golang
PHP
Java
Custom Runtime
使用镜像部署函数
Web 框架部署
通过命令行完成框架部署
快速部署 Egg 框架
快速部署 Express 框架
快速部署 Flask 框架
快速部署 Koa 框架
快速部署 Laravel 框架
快速部署 Nestjs 框架
快速部署 Nextjs 框架
快速部署 Nuxtjs 框架
快速部署 Django 框架
实践教程
最佳实践概述
云产品联合解决方案
业务开发相关实践
实时音视频 TRTC
对象存储 COS
消息队列 CKafka
日志服务CLS
负载均衡 CLB
视频处理 MPS
内容分发网络 CDN
云数据仓库 PostgreSQL
云点播 VOD
短信 SMS
Elasticsearch Service
定时任务
视频处理
客户案例
腾讯在线教育
在线教育行业案例
游戏聊天系统
腾讯互娱国际(IEGG)
API 文档
History
Introduction
API Category
Making API Requests
Other APIs
Namespace APIs
Layer Management APIs
Async Event Management APIs
Trigger APIs
Function APIs
函数和层的状态说明
Data Types
Error Codes
SDK文档
常见问题
通用问题
Web 函数相关问题
计费相关问题
网络相关问题
日志相关问题
SCF 工具相关问题
事件处理相关问题
API 网关触发器相关问题
相关协议
Service Level Agreement
联系我们
词汇表

SCF + COS 数据入湖方案

PDF
聚焦模式
字号
最后更新时间: 2024-12-02 21:04:04

操作场景

Serverless 架构的入湖方案是通过云函数触发器拉起数据调用后,通过云函数捕获并记录批次数据信息,在函数内闭环相关的结构转换和数据格式转换,数据压缩等能力。在本文档示例中,我们用到了云函数 SCF、对象存储 COS 对 TDMQ 消息进行备份。

操作步骤

创建 COS 储存桶

2. 选择左侧“存储桶列表”,单击创建存储桶,新建源 COS Bucket。
3. 设置 COS Bucket 的名称,例如 “scf-data-lake”,地域为“广州” ,设置访问权限为默认值“私有读写” ,单击确定完成创建。

创建消息队列 TDMQ

1. 通过 TDMQ 控制台创建集群和 Topic 等资源,详情可参见 TDMQ 资源创建与准备
2. TDMQ 集群需接入 VPC,详情可参见 VPC 接入

通过 COS 应用集成进行函数配置

2. 选择左侧“应用集成”,在“数据迁移与备份”中选择“TDMQ消息备份”。如下图所示:


3. 在 “TDMQ消息备份”页中,选择已创建的 COS Bucket 所在的地域,并单击添加函数
4. 在“创建TDMQ消息备份函数”弹窗中,进行函数基础配置。输入函数名称,例如 data-lake,并关联已创建的 Bucket scf-data-lake,勾选授权SCF服务后单击下一步
5. 单击下一步,进行 TDMQ 配置,配置项说明如下:
集群选择:选择消息来源的 TDMQ 集群,仅支持同地域的 TDMQ 集群。
命名空间:选择集群中的命名空间。
主题选择:选择消息来源的主题。
订阅选择:选择对应的主题订阅,如现有的订阅不满足需求,可前往 TDMQ 控制台的 消费管理 新建订阅。
起始位置:历史消息的起始位置。
角色选择:选择 TDMQ 角色。TDMQ 的“角色”是 TDMQ 内专有的概念,区别于腾讯云的“角色”,是用户自行在 TDMQ 内部做权限划分的最小单位,用户可以添加多个角色并为其赋予不同命名空间下的生产和消费权限。
角色密钥:选择 TDMQ 的角色密钥。TDMQ 的“密钥”是一种鉴权工具,用户可以通过在客户端中添加密钥来访问 TDMQ 进行消息的生产消费。密钥和角色一一对应,每种角色都有其对应的唯一密钥。
访问地址:必须为 VPC 内网访问地址。
注意:
对应的 VPC 子网中必须有可用的 IP,且必须支持 DHCP。
6. 单击下一步,进行投递配置,配置项说明如下:
投递的路径:备份文件的投递路径前缀,不填写则默认保存在存储桶根路径,指定前缀必须以斜杠/为结尾。
7. 添加配置后,单击确认,即可看到函数已添加完成。 您可以对新创建的函数进行如下操作:
单击查看日志,查看 TDMQ 消息备份的历史运行情况。当备份出现报错时,您还可以通过单击查看日志,快速跳转到云函数控制台查看日志错误详情。
单击编辑,修改 TDMQ 消息备份规则。
单击删除,删除不使用的 TDMQ 消息备份规则。

测试云函数

1. 登录 TDMQ 控制台
2. 选择左侧“Topic管理”,选择地域、当前集群和命名空间。
3. 在“Topic管理”列表页,单击已关联的 Topic 主题右侧的发送消息
4. 在弹出的对话框中输入消息内容。消息长度不超过64KB。
5. 单击提交,完成消息的发送。
6. 进入 COS 已关联桶详情页,例如 scf-data-lake 中已定义的投递的路径,查看是否有文件被创建。如有,则 TDMQ 消息备份成功。

帮助和支持

本页内容是否解决了您的问题?

填写满意度调查问卷,共创更好文档体验。

文档反馈