Naeel
1a94241c62
Компоненты: - iot-operator: controller-manager (IoTDevice CRD) + REST API (порт 9090) - mqtt-bridge: MQTT (EMQX) → Kafka bridge - kafka-consumer: Kafka → Postgres pipeline Модуль: gitea.services.ngcloud.ru/Nail/IoT Все 3 бинарника собираются, import paths адаптированы.
49 lines
1.6 KiB
YAML
49 lines
1.6 KiB
YAML
# Создано: 2026-04-06
|
|
# Deployment iot-kafka-consumer — читает IoT телеметрию из Kafka → пишет в IoT Postgres.
|
|
#
|
|
# Consumer group "iot-pg-consumer" — можно масштабировать горизонтально без дублирования.
|
|
# Offset коммитится ТОЛЬКО после успешной записи в Postgres (at-least-once гарантия).
|
|
#
|
|
# Применение: kubectl apply -f deployments/k8s/iot-kafka-consumer.yaml
|
|
|
|
---
|
|
apiVersion: apps/v1
|
|
kind: Deployment
|
|
metadata:
|
|
name: iot-kafka-consumer
|
|
namespace: sless
|
|
labels:
|
|
app: iot-kafka-consumer
|
|
spec:
|
|
replicas: 1
|
|
selector:
|
|
matchLabels:
|
|
app: iot-kafka-consumer
|
|
template:
|
|
metadata:
|
|
labels:
|
|
app: iot-kafka-consumer
|
|
spec:
|
|
containers:
|
|
- name: kafka-consumer
|
|
# Тот же образ что и оператор — все IoT бинари в одном образе.
|
|
image: pearlharbor.registryk8s.services.ngcloud.ru/naeel/sless-operator:v0.1.69
|
|
imagePullPolicy: Always
|
|
command: ["/iot-kafka-consumer"]
|
|
env:
|
|
- name: KAFKA_BROKERS
|
|
value: "kafka.sless.svc.cluster.local:9092"
|
|
envFrom:
|
|
# IOT_PG_DSN — master DSN для IoT Postgres (per-tenant DB)
|
|
- secretRef:
|
|
name: iot-postgres-secret
|
|
resources:
|
|
requests:
|
|
memory: "32Mi"
|
|
cpu: "25m"
|
|
limits:
|
|
memory: "64Mi"
|
|
cpu: "100m"
|
|
imagePullSecrets:
|
|
- name: sless-registry-auth
|