检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
使用Visual Studio 新增json序列化和反序列化接口,并提供HC.Serverless.Function.Common.JsonSerializer.dll 。 提供的接口如下: T Deserialize<T>(Stream ins):反序列化值传递到Function处理程序的对象中。
运行调试本地函数、部署本地函数至云端 拉取云端的函数列表、调用云端函数、上传ZIP包至云端 前提条件 下载 Visual Studio Code(1.63.0版本以上)并安装。 安装插件 打开Visual Studio Code工具,在应用商店中搜索“Huawei Cloud FunctionGraph”并进行安装。
Kafka实例ID topic_id 主题ID kafka_user 用户名 kafka_password 用户密码 kafka_ssl_enable 是否开启ssl验证(若开启则用户名和密码字段是为必选) batch_size 批次大小 父主题: 函数模型介绍
函数支持json序列化和反序列化 使用NET Core CLI 使用Visual Studio 父主题: 开发事件函数
pycryptodome 安装KooCLI命令行工具 安装KooCLI命令行工具 远程登录购买的ECS云服务器,执行如下命令安装KooCLI: curl -sSL https://hwcloudcli.obs.cn-north-1.myhuaweicloud.com/cli/latest/hcloud_install
serverless invoke --function functionName 选项 --function或-f:要调用的服务中函数的名称,必填。 --data或-d:传递给函数的数据。 --path或-p:JSON文件的路径,其中包含要传递给所调用函数的输入数据。此路径是相对于服务根目录的相对路径。
"memory_size": 256, "runtime": "Python2.7", "timeout": 30, "user_data": "{\"obs_address\":\"obs.example.example.com\",\"srcBucket\":\" xxx\"
网络”,单击安全组名称,跳转到安全组页面。 选择“入方向规则”,查看安全组入方向规则。 实例未开启SSL开关 ▪ 如果是VPC内访问,实例安全组入方向规则,需要允许端口5672的访问。 ▪ 如果是公网访问,需要允许端口15672的访问。 实例已开启SSL开关 ▪ 如果是VPC内访问,实例安全组入方向规则,需要允许端口5671的访问。
网络”,单击安全组名称,跳转到安全组页面。 选择“入方向规则”,查看安全组入方向规则。 实例未开启SSL开关 ▪ 如果是VPC内访问,实例安全组入方向规则,需要允许端口5672的访问。 ▪ 如果是公网访问,需要允许端口15672的访问。 实例已开启SSL开关 ▪ 如果是VPC内访问,实例安全组入方向规则,需要允许端口5671的访问。
#APIG触发器默认对数据进行Base64编码,这里解码 raw_data = base64.b64decode(body) for part in decoder.MultipartDecoder(raw_data, content_type).parts: #这里处理数据
是否必选 参数类型 描述 trigger_status 否 String 触发器状态 枚举值: ACTIVE DISABLED event_data 否 Array of UpdateriggerEventData objects 触发器更新事件 表4 UpdateriggerEventData
TriggerMetadataList objects 触发信息列表 temp_detail TempDetail object user_data String 用户数据 encrypted_user_data String 加密用户数据 dependencies Array of strings 模板所需依赖列表
DISABLED。 枚举值: ACTIVE DISABLED event_type_code 否 String 消息代码。 event_data 是 TriggerEventDataRequestBody object 触发器源事件。 表4 TriggerEventDataRequestBody
"partition_key": "shardId_0000000000", "data": "d2VsY29tZQ==", "sequence_number": "0"
def handler(event, context): data = event["notify_data"]["body"] lat = data["lat"] lng = data["lng"] print(f" WGS84: ({lng}
must be specified because Kafka SASL_SSL is enabled. 若Kafka开启了SASL_SSL协议,所以必须设置对应的用户名和密码 若Kafka开启了SASL_SSL协议,检查是否设置对应的用户名和密码 400 FSS.1114 The subnet
String "触发器状态" ACTIVE: 启用状态。 DISABLED: 禁用状态。 枚举值: ACTIVE DISABLED event_data TriggerEventDataResponseBody object 触发器源事件。 last_updated_time String
String "触发器状态" ACTIVE: 启用状态。 DISABLED: 禁用状态。 枚举值: ACTIVE DISABLED event_data TriggerEventDataResponseBody object 触发器源事件。 last_updated_time String
则手动添加环境变量配置则丢失 user_data = new_config.get('userData', None) if user_data is not None: user_date_json_str = json.dumps(user_data) user_date_json_str
鉴权类型。支持密钥认证接入(SECRET)和证书认证接入(CERTIFICATES)两种方式。使用密钥认证接入方式(SECRET)填写secret字段,使用证书认证接入方式(CERTIFICATES)填写fingerprint字段,不填写auth_type默认为密钥认证接入方式(SECRET)。 secure_access