阿里云函数计算 OSS 触发器配置指南🚀

本指南将帮助你配置阿里云函数计算，使其能够响应 OSS 存储桶的文件上传事件。准备好了吗？Let's go! 🎉

前提条件

• 已创建阿里云账号并完成实名认证。✅
• 已创建 OSS 存储桶。📦
• 已创建函数计算服务和函数。 ⚙️
• 确保函数计算服务具有访问 OSS 资源的权限。🔑

配置步骤

步骤 1: 授权函数计算访问 OSS

如果你的函数计算服务还没有访问 OSS 的权限，你需要创建一个 RAM 角色，并授予该角色访问 OSS 的权限。

1. 登录 RAM 控制台。
2. 创建 RAM 角色，选择 "函数计算" 作为可信实体。
3. 为 RAM 角色添加权限策略，例如 AliyunOSSReadOnlyAccess 或自定义权限策略，允许读取 OSS 资源。
4. 在函数计算服务配置中，指定该 RAM 角色。 在函数配置页面，找到“角色”或“服务角色”，选择你创建的 RAM 角色。

步骤 2: 创建 OSS 触发器

现在，我们将为函数创建 OSS 触发器，以便在文件上传到存储桶时自动触发函数。

1. 登录 函数计算控制台。
2. 找到你要配置触发器的函数，进入函数详情页面。
3. 在 "触发器" 选项卡中，点击 "创建触发器"。

4. 配置触发器参数：

   • 触发器类型: 选择 "OSS 触发器"。
   • 触发器名称: 为触发器指定一个名称，例如 "oss-upload-trigger"。
   • 存储桶: 选择你的 OSS 存储桶。
   • 事件类型: 选择 "ObjectCreated:*" (表示所有对象创建事件)。 你也可以选择更具体的事件，例如 "ObjectCreated:PutObject"。
   • 前缀: （可选）指定触发器只响应特定前缀的文件上传事件。例如，如果只想响应 `images/` 目录下的文件上传，可以设置为 `images/`。
   • 后缀: （可选）指定触发器只响应特定后缀的文件上传事件。例如，如果只想响应 `.jpg` 文件上传，可以设置为 `.jpg`。
   • 角色: 选择有权限读取 OSS 资源的 RAM 角色。 这个角色应该与步骤 1 中配置的角色相同。
   • 函数: 选择要触发的函数。
   • 同步调用: 选择是否同步调用函数。 同步调用会等待函数执行完成，并返回结果。 异步调用则不会等待。
   • 启用触发器: 确保启用触发器。
5. 点击 "创建" 完成触发器配置。

步骤 3: 编写函数代码

函数需要能够处理 OSS 事件。 以下是一个 Python 示例代码，用于读取上传到 OSS 的文件的内容：

    
import oss2
import json
import logging

def handler(event, context):
    logger = logging.getLogger()
    evt = json.loads(event)
    bucket_name = evt['events'][0]['oss']['bucket']['name']
    object_name = evt['events'][0]['oss']['object']['key']

    # 从 context 中获取临时凭证
    creds = context.credentials
    auth = oss2.StsAuth(creds.access_key_id,
                        creds.access_key_secret,
                        creds.security_token)

    # 替换为你的 OSS endpoint
    endpoint = 'oss-cn-hangzhou.aliyuncs.com'
    bucket = oss2.Bucket(auth, endpoint, bucket_name)

    try:
        # 获取文件内容
        object_stream = bucket.get_object(object_name)
        file_content = object_stream.read()
        logger.info(f'File content: {file_content.decode("utf-8")}')
        return f'File {object_name} processed successfully! Content: {file_content.decode("utf-8")}'
    except oss2.exceptions.OssError as e:
        logger.error(f'Error accessing OSS: {e}')
        return f'Error processing file {object_name}: {e}'
    
  

注意:

• 替换 oss-cn-hangzhou.aliyuncs.com 为你的 OSS endpoint。
• 函数需要安装 oss2 库。 你可以在函数计算控制台中配置依赖。
• 确保你的函数有足够的内存和超时时间来处理文件。

步骤 4: 测试触发器

上传一个文件到你配置的 OSS 存储桶。 检查函数是否被触发，并查看函数日志，确认文件内容是否被正确处理。

常见问题

• 函数没有被触发？ 检查触发器配置是否正确，包括存储桶名称、事件类型、前缀、后缀和角色。
• 函数报错？ 检查函数代码是否正确，以及是否缺少依赖。 查看函数日志，获取更多错误信息。
• 权限问题？ 检查函数计算服务是否具有访问 OSS 资源的权限。 确保 RAM 角色配置正确。

恭喜！你已经成功配置了阿里云函数计算 OSS 触发器。 🎉 如果你遇到任何问题，请参考阿里云官方文档或联系技术支持。 Good luck! 🍀