ucalgary/ftrigger

OpenFaaS的Kafka触发器

OpenFaaS（函数即服务）是Alex Ellis开发的框架，用于在Docker Swarm或Kubernetes上简化无服务器函数的部署。本镜像提供的ftrigger工具可配合OpenFaaS API网关使用，通过观察函数服务的标签，根据标签描述的条件自动触发函数。目前仅支持Kafka主题触发器，时间触发器（类似cron）将在后续开发。

核心功能

• 支持Kafka主题触发器，可配置函数响应特定Kafka主题的消息
• 可选择将Kafka消息值或键值对作为函数请求体

使用场景

• 实时数据处理：通过Kafka消息触发函数处理流数据
• 事件驱动业务：基于Kafka事件自动执行OpenFaaS函数
• 微服务集成：实现Kafka与OpenFaaS函数的联动

配置说明

基础函数声明

OpenFaaS函数可声明为Docker服务，若服务容器带有function: 'true'标签，将自动注册到网关：

yaml
echoit:
  image: functions/alpine:health
  labels:
    function: "true"
  environment:
    fprocess: "cat"

配置Kafka触发器

ftrigger会扫描函数服务中匹配ftrigger.*模式的标签，目前仅支持kafka触发器。通过ftrigger.kafka.*标签配置：

• ftrigger.kafka: 'true'：开启Kafka触发器
• ftrigger.kafka.topic: 'echo'：指定响应的Kafka主题
• ftrigger.kafka.data: 'key-value'：设置请求体为包含消息键和值的JSON对象（默认仅发送消息值）

示例配置：

yaml
echoit:
  image: functions/alpine:health
  labels:
    function: "true"
  environment:
    fprocess: "cat"
  deploy:
    labels:
      ftrigger.kafka: 'true'
      ftrigger.kafka.topic: 'echo'
      ftrigger.kafka.data: 'key-value'

测试部署

可通过Play with Docker快速部署，点击以下按钮：

发送Kafka消息测试

1. 获取Kafka服务容器ID：

bash
SERVICE_NAME=ftrigger_kafka
TASK_ID=$(docker service ps --filter 'desired-state=running' $SERVICE_NAME -q)
CONTAINER_ID=$(docker inspect --format '{{ .Status.ContainerStatus.ContainerID }}' $TASK_ID)

2. 执行Kafka生产者发送消息：

bash
docker exec -it $CONTAINER_ID kafka-console-producer --broker-list kafka:9092 --topic echo
# 输入消息（每行一条）

3. 查看网关日志验证函数触发：

bash
docker service logs ftrigger_gateway

维护信息

本仓库及镜像由卡尔加里大学的Research Management Systems项目维护。