检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
设置以下信息。 触发器类型:数据接入服务 (DIS)。 通道名称:选择已创建的DIS通道,例如:dis-function。 起始位置:选择流中开始读取数据的位置。 TRIM_HORIZON:从最早被存储至分区的有效记录开始读取。 latest:从分区中的最新记录开始读取,此设置可以保证你总是读到分区中最新记录。
创建委托 登录统一身份认证服务控制台。 在统一身份认证服务的左侧导航窗格中,选择“委托”菜单,单击右上方的“+创建委托”,如图2所示。 图2 创建委托 开始配置委托。 委托名称:LtsOperation。 委托类型:选择“云服务”。 云服务:选择“函数工作流 FunctionGraph”。
函数名 version-name - 选填 选填 指定版本,不设置默认为latest版本 trigger-type - 选填 必填 触发器类型 trigger-name - 选填 必填 触发器名,APIG为API名称,OBS为桶名,TIMER为触发器名称 assume-yes y
选择待配置的函数,单击进入函数详情页。 选择“设置 > 触发器”,单击“创建触发器”,弹出“创建触发器”对话框。 图1 创建触发器 设置以下信息。 触发器类型:选择“开源Kafka(OPENSOURCEKAFKA)”。 连接地址: 搭建kafka的broker地址列表,以逗号分隔。 主题: 用户自建的topic。
选择待配置的函数,单击进入函数详情页。 选择“设置 > 触发器”,单击“创建触发器”,弹出“创建触发器”对话框。 图1 创建触发器 设置以下信息。 触发器类型:选择“云日志服务(LTS)”。 日志组:选择已创建的日志组,例如:LogGroup1。 日志流:选择已创建的日志流,例如:LogStream1。
函数同步调用响应正文有效负载大小 6MB 否 函数异步调用请求正文有效负载大小 256KB 否 函数导入的资源大小 zip格式压缩文件,大小50MB以内 否 单个自定义镜像函数最大允许镜像大小 10GB 否 函数导出资源包大小 50MB以内 否 租户级别实例数限制 1000 是 函数最大申请内存 10G 否
keys) Alibaba Cloud (alibaba) AWS (aws) Azure (azure) Baidu Cloud (baidu) Google Cloud (google) > Huawei Cloud (huawei) Tencent
选择待配置的函数,单击进入函数详情页。 选择“设置 > 触发器”,单击“创建触发器”,弹出“创建触发器”对话框。 图1 创建触发器 设置以下信息。 触发器类型:选择“分布式消息服务(Kafka)”。 实例:选择已创建专享版Kafka实例。 主题:选择专享版Kafka实例的Topic。 批处理大小:每次从Topic消费的消息数量。
表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目 ID,获取方式请参见获取项目ID。 depend_id 是 String 依赖包的ID。 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是
回到latest版本别名界面,编辑alias,灰度版本选择V2,调整权重,实现V1到V2的灰度升级。 权重用于分派接收到的流量给后端版本,具体数值视业务情况自定义。 图4 编辑别名 创建V3版本,编辑alias,对应版本设置为V2,灰度版本选择V3,调整权重,实现V2到V3的灰度升级。 图5 创建V3版本
桶名称输入:“hugb-bucket-input” 默认存储类别:“标准存储” 桶策略:"私有" 服务端加密:“关闭” 归档数据直读:“关闭” 单击“立即创建”,完成源桶创建。 重复步骤2,创建目标桶。 区域及存储类别与源桶保持一致,桶名称命名为“hugb-bucket-output”。
ut” 数据冗余存储策略:“单AZ存储” 默认存储类别:“标准存储” 桶策略:"私有" 服务端加密:“不开启加密” 归档数据直读:“关闭” 其余参数保持默认,单击“立即创建”,完成源桶创建。 重复2,创建目标桶。 区域及存储类别与源桶保持一致,桶名称命名为“your-bucket-output”。
单击“创建函数”,进入创建函数流程。 选择“创建空白函数”,填写函数配置信息。 输入基础配置信息,完成后单击“创建函数”。 函数类型:事件函数 函数名称:输入“fss_examples_dew” 委托名称:选择创建委托中创建的“serverless_trust” 运行时语言:选择“Java8” 进入fss_exa
选择待配置的函数,单击进入函数详情页。 选择“设置 > 触发器”,右侧单击“创建触发器”,弹出“创建触发器”对话框。 设置以下信息。 触发器类型:选择“设备接入(IoTDA)”。 实例:选择已经创建好的IoTDA实例。 数据来源、触发事件、资源空间:详情请参见表1。 表1 配置说明
triggers字段介绍 trigger 字段 表1 trigger参数说明 参数名 必填 类型 参数描述 triggerTypeCode True String 触发器类型。 status False Enum 触发器状态,取值为 ACTIVE、DISABLED,默认为 ACTIVE。
离线异步任务场景 特征 在离线异步应用场景中,工作负载具有以下一个或多个特征: 执行时间长 业务的处理耗时一般在分钟~小时级,Response Time不敏感。 提交后立即返回 在触发调用后立即得到返回,从而不因长耗时处理阻塞业务主逻辑的执行。 实时感知任务状态 无 并行处理 离
数据冗余存储策略:“单AZ存储” 桶名称输入:“dew-bucket-input” 默认存储类别:“标准存储” 桶策略选择:"私有" 归档数据直读:“关闭” 单击“立即创建”,完成源桶创建。 重复步骤2,创建目标桶。 区域及存储类别与源桶保持一致,桶名称命名为“dew-bucket-output”。
前提条件 (1)函数中的IP地址为LTS的接入点,获取接入点IP方法如下: 登录云日志服务 LTS控制台,在左侧导航栏选择“主机管理 > 主机”; 在页面右上方,单击“安装ICAgent”; 在弹出的“安装ICAgent”窗口中获取接入点IP。 图1 接入点IP (2)函数中的log_g
创建功能函数 创建实现日志提取功能的函数,将示例代码包上传。创建过程请参考创建函数,运行时语言选择“Python2.7”,委托名称选择创建委托中的“LtsOperation”。 函数实现的功能是:将收到的日志事件数据进行base64解码,然后提取出包含“WRN”、“WARN”、“ER
Yaml文件 字段解析 表1 参数说明 参数 必填 类型 参数描述 region True Enum 地域 function True Struct 函数 triggers False Struct 触发器 Yaml完整配置 华为云函数工作流(FunctionGraph)组件的Yaml字段如下: