OpenFaaS и Knative: serverless на своих серверах

У нас в «ДатаПайп» мы активно обрабатываем данные, и, представьте себе, у нас в работе сейчас более 200 событийных функций! На старте наш стек выглядел так: мы использовали AWS Lambda для 150 функций и наш собственный Kubernetes, где крутилось ещё 50 функций на обычных pods. И вот с чем мы столкнулись, какие у нас были "боли":

• Стоимость Lambda: $8,000/мес за event-driven обработку, растёт линейно
• Cold starts: Lambda на Java — 3-5 секунд первый запуск
• Vendor lock-in: функции используют AWS-specific SDK, миграция — переписывание
• Kubernetes-функции: нет auto-scale-to-zero, pods работают 24/7 даже без нагрузки

On-premise serverless устроен так: функции сами масштабируются от 0 до N подов. Нет нагрузки — 0 подов, ноль потраченных ресурсов. Пошла нагрузка — поды поднимаются автоматически.

# Установка OpenFaaS через arkade
curl -sLS https://get.arkade.dev | sh
arkade install openfaas

# Или через Helm
helm repo add openfaas https://openfaas.github.io/faas-netes/
helm install openfaas openfaas/openfaas \
  --namespace openfaas --create-namespace \
  --set functionNamespace=openfaas-fn \
  --set generateBasicAuth=true

# Получение пароля
PASSWORD=$(kubectl get secret -n openfaas basic-auth -o jsonpath="{.data.basic-auth-password}" | base64 -d)

# Логин
faas-cli login --username admin --password $PASSWORD --gateway http://gateway.openfaas:8080

Создание и деплой функции:

# Создание функции на Python
faas-cli new process-order --lang python3-http
# Создаст:
# process-order/handler.py — код функции
# process-order.yml — конфигурация

# handler.py
def handle(event, context):
    order = event.body
    # Обработка заказа...
    result = {"status": "processed", "order_id": order.get("id")}
    return {"statusCode": 200, "body": result}

# Сборка и деплой
faas-cli build -f process-order.yml
faas-cli push -f process-order.yml
faas-cli deploy -f process-order.yml

# Вызов
curl -X POST http://gateway:8080/function/process-order \
  -H "Content-Type: application/json" \
  -d '{"id": 12345, "items": [{"sku": "A1", "qty": 2}]}'

# Установка Knative Serving
kubectl apply -f https://github.com/knative/serving/releases/download/knative-v1.14.0/serving-crds.yaml
kubectl apply -f https://github.com/knative/serving/releases/download/knative-v1.14.0/serving-core.yaml

# Networking (Kourier — лёгкий вариант)
kubectl apply -f https://github.com/knative/net-kourier/releases/download/knative-v1.14.0/kourier.yaml
kubectl patch configmap/config-network -n knative-serving \
  --type merge -p '{"data":{"ingress-class":"kourier.ingress.networking.knative.dev"}}'

# Knative Eventing (для event-driven)
kubectl apply -f https://github.com/knative/eventing/releases/download/knative-v1.14.0/eventing-crds.yaml
kubectl apply -f https://github.com/knative/eventing/releases/download/knative-v1.14.0/eventing-core.yaml

Деплой функции через Knative Service:

apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: order-processor
  namespace: production
spec:
  template:
    metadata:
      annotations:
        autoscaling.knative.dev/min-scale: "0"    # Scale to zero
        autoscaling.knative.dev/max-scale: "50"   # Max 50 pods
        autoscaling.knative.dev/target: "100"     # 100 concurrent requests per pod
    spec:
      containers:
      - image: registry.datapipe.ru/order-processor:v1.2
        resources:
          requests:
            memory: 128Mi
            cpu: 100m
          limits:
            memory: 512Mi
            cpu: 500m
        env:
        - name: DB_HOST
          value: postgres.production.svc

# Knative автоматически:
# 1. Масштабирует от 0 до 50 pod-ов по нагрузке
# 2. Создаёт route и traffic splitting для canary
# 3. Убивает pod-ы через 30 сек без трафика

Knative Eventing подключает функции к источникам событий: Kafka, RabbitMQ, Cron, GitHub webhooks.

# KafkaSource → функция order-processor
apiVersion: sources.knative.dev/v1beta1
kind: KafkaSource
metadata:
  name: orders-source
spec:
  consumerGroup: order-processors
  bootstrapServers:
  - kafka.production.svc:9092
  topics:
  - new-orders
  sink:
    ref:
      apiVersion: serving.knative.dev/v1
      kind: Service
      name: order-processor

Результат: при появлении сообщения в Kafka topic «new-orders» Knative автоматически запускает pod order-processor (если был в zero), передаёт событие, обрабатывает, масштабирует по нагрузке.