检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
分布式消息服务Kafka版与开源Kafka的差异说明，请参见Kafka与开源Kafka的差异。 对于处理失败的Kafka数据，Kafka触发器会丢弃过大记录（>6MB）。 前提条件 进行操作之前，需要做好以下准备。 已经创建函数，创建过程请参见使用空白模板创建函数。 创建Kafka触发器
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
return client def initializer(context): global redis_client redis_client = create_redis_client(context) redis_client.ping()
使用Redis连接池进一步复用已创建的连接，有效提升程序性能；同时，Redis提供了最大连接数配置确保连接资源的使用保持在一个可控范围内，并且能够确保线程安全。 最大连接数配置区间：在FunctionGraph函数配置Redis最大连接数建议在如下区间选取一个值： 最大连接数下限 =
format(value)) return value 客户端使用连接池时不要将获取连接的操作放在初始化函数 initializer 方法中，否则只会在初始化时获取一个连接而导致连接池使用无效。当网络抖动时可能会使已获取的连接断连，后续复用该实例的并发请求时可能会因断连而访问redis失败。
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
initializer(context): global redis_client redis_client = create_redis_client(context) redis_client.ping() 图1 初始化函数配置 这里用到了FunctionGra
函数无法通过VPC连接对应的Redis？ 问题现象 相同的代码，函数能通过VPC1连通Redis1，但是不能通过VPC2连通Redis2。 解决方案 与客户确认问题现象，Redis1在VPC1中，Redis2在VPC2中，Redis客户端代码是同一套代码。 查看连接报错信息如下，通
"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"
"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触发器吗？
的使用请参考使用DDS触发器。 分布式消息服务Kafka版 使用Kafka触发器，当向Kafka实例的Topic生产消息时，FunctionGraph会消费消息，触发函数以执行额外的工作，关于Kafka触发器的使用请参见使用Kafka触发器。 云监控服务CES FunctionG
模拟SMN事件，触发函数。 定时触发器（TIMER） 模拟TIMER事件，触发函数。 分布式消息服务 Kafka版（KAFKA） 模拟Kafka事件，触发函数。 开源Kafka（OPENSOURCEKAFKA） 模拟开源Kafka事件，触发函数。 分布式消息服务 RabbitMQ版（RABBITMQ） 模拟RabbitMQ事件，触发函数。
使用APIG专享版触发器 使用APIG共享版触发器 使用APIC触发器 使用CTS触发器 使用DDS触发器 使用DIS触发器 使用Kafka触发器 使用RabbitMQ触发器 使用开源Kafka触发器 使用GeminiDB Mongo触发器 使用IoTDA触发器 使用LTS触发器 使用SMN触发器 使
准备 购买Redis实例，如果已有Redis实例可以跳过。 查看Redis实例的连接信息，获取待连接Redis实例的IP地址。具体步骤请参见查看实例信息。 创建一个有“VPC Administrator”权限的FunctionGraph云服务委托，配置委托权限请参见配置委托权限。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
