检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
事件源介绍请参见支持的事件源。 分布式消息服务Kafka版与开源Kafka的差异说明，请参见Kafka与开源Kafka的差异。 对于处理失败的Kafka数据，Kafka触发器会丢弃过大记录（>6MB）。 前提条件 进行操作之前，需要做好以下准备。 已经创建函数，创建过程请参见使用空白模板创建函数。
FunctionGraph和kafka必须在同一个子网内，才可以在FunctionGraph中配置Kafka触发器吗？ 是必须的。在创建函数的时候会判断子网是否相同，不允许一个VPC的不同子网进行连接。 父主题： 触发器管理
递来调用函数。 分布式消息服务Kafka版与开源Kafka的差异说明，请参见Kafka与开源Kafka的差异。 对于处理失败的Kafka数据，Kafka触发器会丢弃过大记录（>6MB）。 前提条件 进行操作之前，需要做好以下准备。 已经创建函数。 创建Kafka触发器，必须开启函数工作流VPC访问，请参见配置网络。
strings KAFKA主题id列表（KAFKA触发器参数）。KAFKA触发器此参数必填。 kafka_user 否 String KAFKA账户名（KAFKA触发器参数）。 kafka_password 否 String KAFKA账户密码（KAFKA触发器参数）。 kafka_connect_address
initializer(context): global redis_client redis_client = create_redis_client(context) redis_client.ping() 图1 初始化函数配置 这里用到了FunctionGra
Array of strings KAFKA主题id列表（KAFKA触发器参数）。 kafka_user String KAFKA账户名（KAFKA触发器参数）。 kafka_password String KAFKA账户密码（KAFKA触发器参数）。 kafka_connect_address
Array of strings KAFKA主题id列表（KAFKA触发器参数）。 kafka_user String KAFKA账户名（KAFKA触发器参数）。 kafka_password String KAFKA账户密码（KAFKA触发器参数）。 kafka_connect_address
Array of strings KAFKA主题id列表（KAFKA触发器参数）。 kafka_user String KAFKA账户名（KAFKA触发器参数）。 kafka_password String KAFKA账户密码（KAFKA触发器参数）。 kafka_connect_address
FunctionGraph函数是否支持扩展？ FunctionGraph目前已经集成了一些非标准库如：redis、http、obs_client等，开发函数时可以直接使用，详情请参考开发指南。 用户可以通过维护属于自己的依赖代码库，供所有函数使用，请参考依赖包管理。 父主题： 通用问题
"size" : 577118, "name" : "python-kafka", "description" : "python支持kafka操作的库", "file_name" : "python-kafka.zip", "version" : 0, "last_modified"
"size" : 577118, "name" : "python-kafka", "description" : "python支持kafka操作的库", "file_name" : "python-kafka.zip", "version" : 0, "dep_id"
定时器TIMER 异步调用 云日志服务LTS 异步调用 云审计服务CTS 异步调用 文档数据库服务DDS 异步调用 分布式消息服务Kafka版 异步调用 分布式消息服务RabbitMQ版 异步调用 云数据库GeminiDB Mongo 异步调用 以下触发器：API网关APIG、AP
触发器类型代码。（当前OBS触发器暂不支持中国站。） 枚举值： TIMER APIG CTS DDS DMS DIS LTS OBS SMN KAFKA RABBITMQ DEDICATEDGATEWAY OPENSOURCEKAFKA APIC GeminiDB Mongo EVENTGRID
"string", "kafka_ssl_enable": string， "batch_size": int, } 表11 Kafka触发器数据说明 字段名称 字段说明 instance_id Kafka实例ID topic_id 主题ID kafka_user 用户名
如何使用APIG触发器调用函数？ 使用APIG触发器，函数如何获取请求路径或请求参数？ FunctionGraph和kafka必须在同一个子网内，才可以在FunctionGraph中配置Kafka触发器吗？
使用APIG（专享版）触发器 使用Kafka触发器 使用DIS触发器 使用SMN触发器 使用LTS触发器 使用CTS触发器 使用DDS触发器 使用GeminiDB Mongo触发器 使用APIG触发器 使用APIC触发器 使用RabbitMQ触发器 使用开源Kafka触发器 使用IoTDA触发器
return client def initializer(context): global redis_client redis_client = create_redis_client(context) redis_client.ping()
定时触发器（TIMER） 模拟TIMER事件，触发函数。 分布式消息服务 Kafka版（KAFKA） 模拟Kafka事件，触发函数。 开源Kafka（OPENSOURCEKAFKA） 模拟开源Kafka事件，触发函数。 分布式消息服务 RabbitMQ版（RABBITMQ） 模拟RabbitMQ事件，触发函数。
must be the same as that of the Kafka instance. 函数的子网与kafka实例所在的子网不一样 检查函数的子网与Kafka实例所在的子网是否一致 400 FSS.1116 Kafka instance configuration error.
initializer(context): global redis_client redis_client = create_redis_client(context) redis_client.ping() def handler(event, context):
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
