云函数 示例说明(SCF + COS 实现 MapReduce)

这篇说说使用云函数(SCF)处理COS对象创建事件,实现自动统计上传文这篇件字数的方案,并强调避免使用同一存储桶导致无限循环。 实现流程:用户上传文件至源COS桶触发事件,SCF调用函数获取文件并统计字数,结果保存至目标桶。 注意事项:需使用三个不同COS桶(源、中间、目标),且函数与桶需在同一地域,避免循环触发。

相关产品
云函数 产品页,含版本规格、价格与购买入口。

本教程假设以下情况:

·你将不定时上传一些文这篇件(例如日志等)至某个特定的 COS Bucket。

·你要对这些文这篇件进行字数统计。

一、实现概要

下面是该函数的实现流程:

·创建函数与 COS Bucket。

·用户将对象上传到 COS 中的源存储桶(对象创建事件)。

·COS Bucket 检测到对象创建事件。

·COS 调用函数并将事件数据作为参数传递给函数,由此将 cos:ObjectCreated:* 事件发布给函数。

·SCF 平台接收到调用请求,执行函数。

·函数通过收到的事件数据获得了 Bucket 名称和文件名称,从该源 Bucket中获取该文件,根据代码中实现的 wordcount 进行字数统计,然后将其保存到目标 Bucket 上。

请注意,完成本教程后,你的账户中将具有以下资源:

·两个 SCF 函数:Mapper 和 Reducer。

·三个 COS Bucket:srcmr、middlestagebucket 和 destmr。

·Mapper 函数将会绑定 srcmr 触发,Reducer 函数将会绑定 middlestagebucket 触发,destmr 将会用来接收最终的统计结果。

赞 (0)
上一篇 4天前
下一篇 4天前