rename: IOT_KAFKA_DEMO -> IOT_RMQ_DEMO (Kafka gone, RabbitMQ is the queue)

2026-07-22 09:28:06 +04:00
parent b72c1e0517
commit 8b888666d7
9 changed files with 2 additions and 0 deletions
@@ -0,0 +1,51 @@
+# =============================================================================
+# Producer (Node.js) — генерирует IoT-события и шлёт в RabbitMQ
+# Каждые 3 сек создаёт случайное событие от одного из 8 датчиков
+# Переменные окружения попадают в K8s под через json_env
+# =============================================================================
+
+locals {
+  # Достаём реальные значения из созданного RabbitMQ (state_out_flat + vault_secrets)
+  prod_rmq_host = nubes_rabbitmq.main.state_out_flat["internalConnect"]      # K8s-хост RabbitMQ
+  prod_rmq_user = nonsensitive(nubes_rabbitmq.main.vault_secrets["adminUser"])  # логин RabbitMQ
+  prod_rmq_pass = nonsensitive(nubes_rabbitmq.main.vault_secrets["adminPass"])  # пароль RabbitMQ
+}
+
+resource "nubes_nodejs" "producer" {
+  resource_name = local.prod_resource_name  # имя в личном кабинете
+
+  startup_configuration = {
+    resource_realm = var.realm  # K8s-кластер
+  }
+
+  cluster_configuration = {
+    cpu      = local.prod_cpu       # CPU millicores
+    memory   = local.prod_memory    # память MB
+    replicas = local.prod_replicas  # количество подов
+  }
+
+  access_configuration = {
+    domain = local.prod_domain  # поддомен для HTTP-доступа
+  }
+
+  app_configuration = {
+    version     = "22"                   # версия Node.js
+    git_path    = local.prod_git_path    # Git-репо с кодом
+    health_path = "/"                    # эндпоинт для health-check'а
+  }
+
+  git_revision      = local.prod_git_revision  # коммит для деплоя
+  operation_timeout = local.prod_timeout       # таймаут
+
+  # Переменные окружения в K8s поде (доступны через process.env)
+  json_env = jsonencode({
+    RABBIT_HOST      = local.prod_rmq_host     # хост RabbitMQ
+    RABBIT_PORT      = "5672"                  # порт AMQP
+    RABBIT_USER      = local.prod_rmq_user     # логин
+    RABBIT_PASS      = local.prod_rmq_pass     # пароль
+    RABBIT_QUEUE     = local.rmq_queue         # имя очереди
+    PRODUCE_INTERVAL = "3"                     # интервал между событиями (сек)
+  })
+
+  depends_on = [nubes_rabbitmq.main]  # ждать создания RabbitMQ
+}