检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
rocketMQ类型事件源 source_community_rocketmq SourceCommunityMQParameters object 社区版rocketMQ类型事件源 source_dms_rocketmq SourceDMSMQParameters object 华为云
object 事件规则,包括过滤规则和转换规则 option 否 RunOption object 运行时配置信息 表4 EventStreamingSource 参数 是否必选 参数类型 描述 source_kafka 否 SourceKafkaMQParameters object 华为云
OBS:DWR:ObjectCreated:POST OBS应用事件源 OPENAPI 3.0 使用Post请求创建或覆盖对象。 OBS:DWR:ObjectRemoved:Delete OBS应用事件源 OPENAPI 3.0 指定对象版本号删除对象。
选择提供方:选择“华为云” 事件目标:选择“FunctionGraph(函数计算)” 函数:选择步骤三中创建的“test”函数 版本:选择“latest” 类型:选择“透传” 图5 配置事件目标参数 单击“确定”,完成事件目标的配置。 单击“保存”,完成事件订阅的配置。
output_bucket index.py文件中定义的存放输出图片的OBS桶参数值your-bucket-output, 创建OBS桶中创建的存放输出图片OBS桶。 添加依赖包。
事件网格支持以对象数组封装的方式进行批量事件发送,其中数组中每个元素都需要遵循CloudEvents V1.0标准格式要求。 更多详情请参见CloudEvents SDK。
目前支持webhook:http连接;kafka:华为云官方kafka实例 枚举值: WEBHOOK KAFKA kafka_detail KafkaConnectionDetail object created_time String 创建UTC时间 updated_time String
目前支持webhook:http连接;kafka:华为云官方kafka实例 枚举值: WEBHOOK KAFKA kafka_detail KafkaConnectionDetail object created_time String 创建UTC时间 updated_time String
在事件追踪中查看事件投递信息 在EG控制台界面,单击“事件通道”中对应的事件通道的“事件轨迹”可以看到该事件的投递详情和事件详情: 界面入口: 图1 界面入口 事件详情: 图2 事件详情 事件轨迹: 图3 事件轨迹 父主题: 实施步骤
配置“任务对象配置”。 图4 任务对象配置 表3 任务对象配置参数说明 参数 说明 Topics 选择“正则表达式”或“输入/选择”。 说明: 当选择“正则表达式”时需在下方输入表达式。 同步消费进度 请选择是否打开。 说明: 打开后会将消息消费进度同步到目标Kafka。
如果需要查询超过7天的操作记录,您必须配置转储到对象存储服务(OBS)或云日志服务(LTS),才可在OBS桶或LTS日志组里面查看历史事件信息。否则,您将无法追溯7天以前的操作记录。
通知组 当通知方式选择通知组时,需要在此选择您的通知组,如您还未创建通知组,创建方式可参考创建通知对象/通知组。 通知对象 当通知方式选择主题订阅时,需要在此选择您的联系人和主题,若没有您想要选择的主题,创建方式可参考创建通知对象/通知组。
解决方式:返回配置专享版事件流作业的第二步,即“源和目标对象配置”页面,重新选择符合实例版本要求的实例作为源端实例。 原因二:目标端RocketMQ实例版本不支持,请选择符合要求的实例。
解决方式:返回配置专享版事件流作业的第二步,即“源和目标对象配置”页面,重新选择符合实例版本要求的实例作为源端实例。 原因二:目标端Kafka实例版本不支持,请选择符合要求的实例。
通知组 当通知方式选择通知组时,需要在此选择您的通知组,如您还未创建通知组,创建方式可参考创建通知对象/通知组。 通知对象 当通知方式选择主题订阅时,需要在此选择您的联系人和主题,若没有您想要选择的主题,创建方式可参考创建通知对象/通知组。
通知组 当通知方式选择通知组时,需要在此选择您的通知组,如您还未创建通知组,创建方式可参考创建通知对象/通知组。 通知对象 当通知方式选择主题订阅时,需要在此选择您的联系人和主题,若没有您想要选择的主题,创建方式可参考创建通知对象/通知组。
”: [“.jpg”]}] data JSON对象 事件数据,条件值位于JSON对象中,条件值为子匹配字段,支持最多5层嵌套结构 示例: {“state”: [{“op”: “StringIn”, “values”: [“running”]}] 父主题: 事件规则
单击“下一步:源和目标对象配置”,进入“源和目标对象配置”页面。 图3 源数据和目标数据配置 表2 源数据和目标数据配置参数说明 参数 说明 配置类型 默认为“Rocketmq实例”。 说明: 配置类型根据实例类型变更。 实例别名 请输入实例别名。
单击“下一步:源和目标对象配置”,进入“源和目标对象配置”页面。 “源数据”和“目标数据”中选择好Kafka实例后,单击“测试连通性”,检查通过后,进入步骤6。 图3 源数据和目标数据配置 表2 源数据和目标数据配置参数说明 参数 说明 配置类型 默认为“Kafka实例”。
监控指标 表1 事件投递监控项 指标ID 指标名称 指标含义 取值范围 测量对象 监控周期(原始指标) num 投递数量 该指标用于统计事件投递的调用总数。