检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
案例概述 场景介绍 该案例演示客户如何使用FunctionGraph 与IoTDA 服务组合,处理物联网设备上报以及设备状态变动的相关数据。物联网设备在IoTDA 平台进行管理,设备产生的数据可以从IoTDA直接流转触发FunctionGraph 的函数运行。用户可以根据需要编写函数处理这些数据。
描述 type 否 String 指标类型,默认值为failcount。 start_time 否 String 起始时间。 end_time 否 String 结束时间。 limit 否 String 指标类型,默认值为failcount。 请求参数 表3 请求Header参数 参数
fgs_func_scale_down_timeout:v1版本函数的实例闲置释放时间 fgs_func_occurs:v1版本函数为实例数配额,v2版本函数为预留实例配额 fgs_func_pat_idle_time:v1版本vpc函数的pat容器闲置释放时间 fgs_func_num:用户函数数量配额 fg
Long 模板版本 template_guide String 模板指南 create_time Long 模板创建时间 update_time Long 模板更新时间 resources Array of AppTemplateResourceDetail objects 模板资源
已开启函数访问VPC内资源的网络配置,开启后需在Kafka服务安全组配置对应子网的权限,请参见配置网络。函数的网络配置需要和创建Kafka的ECS节点网络配置一样,包括VPC和子网。 创建开源Kafka触发器 登录函数工作流控制台,在左侧的导航栏选择“函数 > 函数列表”。 选择待配置的函数,单击进入函数详情页。
必须提供该字段,inline和obs不需要提供。 code_size Long 函数大小,单位:字节。 digest String 函数代码SHA512 hash值,用于判断函数是否变化。 last_modified String 函数最后一次更新时间。 func_code FuncCode
分布式消息服务RabbitMQ: 已创建RabbitMQ实例,创建操作请参见购买RabbitMQ实例。 创建Vhost、Exchange和Queue。 创建RabbitMQ Vhost,创建操作请参见创建RabbitMQ Vhost。 创建RabbitMQ Exchange,创建操作请参见创建RabbitMQ
= update_cmd + f' --app_xrole="{app_xrole_config}"' # 配置初始化入口和初始化超时时间 initializer_handler = new_config.get('initializerHandler', None)
RuntimeException(e); } } } } 创建函数 创建函数的时候,必须选择委托包含OBS和DEW访问权限的委托,否则不能使用OBS和DEW服务。 登录函数工作流控制台,在左侧导航栏选择“函数 > 函数列表”,进入函数列表界面。 单击“创建函数”,进入创建函数流程。
String 测试事件名称。 content String 测试事件content。 last_modified Number 上次修改的时间。 状态码: 400 表4 响应Body参数 参数 参数类型 描述 error_code String 错误码 error_msg String
ListEventsResult 参数 参数类型 描述 id String 测试事件ID。 last_modified Number 上次修改的时间。 name String 测试事件名称。 状态码: 400 表5 响应Body参数 参数 参数类型 描述 error_code String
String 别名对应的版本名称。 description String 别名描述信息。 last_modified String 别名最后修改时间。 alias_urn String 版本别名唯一标识。 additional_version_weights Map<String,Integer>
应用id name String 应用名称 status String 应用状态 last_modified_time Long 最后修改时间 description String 应用描述 状态码: 400 表6 响应Body参数 参数 参数类型 描述 error_code String
必须提供该字段,inline和obs不需要提供。 code_size Long 函数大小,单位:字节。 digest String 函数代码SHA512 hash值,用于判断函数是否变化。 last_modified String 函数最后一次更新时间。 func_code FuncCode
200 表3 响应Body参数 参数 参数类型 描述 name String 应用名称 last_modified_time Long 最后修改时间 stack_resources StackResource object 资源栈 status String 应用状态 stack_name
String 别名对应的版本名称。 description String 别名描述信息。 last_modified String 别名最后修改时间。 alias_urn String 版本别名唯一标识。 additional_version_weights Map<String,Integer>
模板函数执行入口 code_type String 代码类型 code String 代码文件 timeout Integer 函数执行超时时间,超时函数将被强行停止,范围3~259200秒。 memory_size Integer 内存大小 trigger_metadata_list
file_name String 依赖包文件名。 version Long 依赖包版本号 last_modified Long 依赖包更新时间 dep_id String 依赖包ID download_link String 依赖包文件临时下载链接 is_shared Boolean
模板函数执行入口 code_type String 代码类型 code String 代码文件 timeout Integer 函数执行超时时间,超时函数将被强行停止,范围3~259200秒。 memory_size Integer 内存大小 trigger_metadata_list
description String 依赖包描述。 version Long 依赖包版本号 last_modified Long 依赖包更新时间 dep_id String 依赖包ID is_shared Boolean 是否共享(已废弃) 状态码: 401 表6 响应Body参数