Blog

#include <ESP8266WiFi.h>
#include <WiFiClientSecure.h>
#include "DHT.h"
#include "time.h"

#define DHTPIN 2
#define DHTTYPE DHT22
DHT dht(DHTPIN, DHTTYPE);

// 🔹 Wi-Fi 정보 
const char* ssid_farm = "wifi_name";
const char* pass_farm = "wifi_pw";
const char* ssid_home = "wifi_name";
const char* pass_home = "wifi_pw";

// 🔹 Cloud Run 엔드포인트
const char* host = "cloud_run_endpoint_name"; //Cloud Run에서 만든 엔트포인트 주소
const int httpsPort = 443;

// 🔹 장비 ID
String deviceId = "device_name";  // 여러 재배기에 설치한다면 재배기마다 이름

// 🔹 NTP 서버 (한국시간)
const char* ntpServer = "pool.ntp.org";
const long gmtOffset_sec = 9 * 3600;  // GMT+9
const int daylightOffset_sec = 0;

void setupWiFi() {
  Serial.println("📡 Wi-Fi 연결 시도 중...");

  // 1️⃣ 집 Wi-Fi 시도
  WiFi.begin(ssid_home, pass_home);
  for (int i = 0; i &lt; 15 &amp;&amp; WiFi.status() != WL_CONNECTED; i++) {
    delay(1000);
    Serial.print(".");
  }

  // 2️⃣ 실패 시 농장 Wi-Fi 시도
  if (WiFi.status() != WL_CONNECTED) {
    Serial.println("\n❌ 집 Wi-Fi 연결 실패 → 농장 Wi-Fi 시도");
    WiFi.begin(ssid_farm, pass_farm);
    for (int i = 0; i &lt; 15 &amp;&amp; WiFi.status() != WL_CONNECTED; i++) {
      delay(1000);
      Serial.print(".");
    }
  }

  if (WiFi.status() == WL_CONNECTED) {
    Serial.println("\n✅ Wi-Fi 연결 성공");
    Serial.print("IP 주소: ");
    Serial.println(WiFi.localIP());
  } else {
    Serial.println("\n❌ Wi-Fi 연결 실패. 1분 후 재시도 예정");
  }
}

void setup() {
  Serial.begin(115200);
  delay(2000);
  Serial.println("🔌 NodeMCU 부팅 중...");

  setupWiFi();
  dht.begin();

  // 시간 동기화
  configTime(gmtOffset_sec, daylightOffset_sec, ntpServer);
  Serial.println("⏰ 한국시간 동기화 중...");
  delay(2000);
}

void loop() {
  if (WiFi.status() != WL_CONNECTED) {
    setupWiFi();
  }

  float temperature = dht.readTemperature();
  float humidity = dht.readHumidity();

  if (isnan(temperature) || isnan(humidity)) {
    Serial.println("⚠️ DHT22 읽기 실패, 30초 후 재시도");
    delay(30000);
    return;
  }

  struct tm timeinfo;
  if (!getLocalTime(&amp;timeinfo)) {
    Serial.println("⏱ NTP 시간 불러오기 실패");
    delay(30000);
    return;
  }

  char timeString&#91;30];
  strftime(timeString, sizeof(timeString), "%Y-%m-%d %H:%M:%S", &amp;timeinfo);
  String localTime = String(timeString);

  // HTTPS 연결
  WiFiClientSecure client;
  client.setInsecure();  // SSL 검증 비활성화

  Serial.print("☁️ Cloud Run 연결 중...");
  if (!client.connect(host, httpsPort)) {
    Serial.println("❌ 연결 실패");
    delay(60000);
    return;
  }
  Serial.println("✅ 연결 성공!");

  // JSON 데이터 생성
  String jsonData = String("{\"deviceId\":\"") + deviceId +
                    "\",\"temperature\":" + temperature +
                    ",\"humidity\":" + humidity +
                    ",\"createdAt\":\"" + localTime + "\"}";

  // HTTP POST 요청
  client.println("POST / HTTP/1.1");
  client.println("Host: " + String(host));
  client.println("Content-Type: application/json");
  client.print("Content-Length: ");
  client.println(jsonData.length());
  client.println();
  client.println(jsonData);

  // 응답 처리
  while (client.connected()) {
    String line = client.readStringUntil('\n');
    if (line == "\r") break;
  }
  String response = client.readString();
  Serial.println("서버 응답:");
  Serial.println(response);

  client.stop();

  // 시리얼 출력
  Serial.println("🌡 데이터 전송 완료");
  Serial.print("시간: "); Serial.println(localTime);
  Serial.print("온도: "); Serial.print(temperature);
  Serial.print(" °C, 습도: "); Serial.print(humidity); Serial.println(" %");

  // 20분 대기 (1200초)
  Serial.println("⏳ 다음 측정까지 20분 대기...");
  delay(1200 * 1000);
}

CREATE OR REPLACE TABLE `table_name` AS
SELECT
  FORMAT_DATETIME(
    '%Y-%m-%d %H:%M:%S',
    DATETIME(timestamp, "Asia/Seoul")
  ) AS createdAt_kst,
  SAFE_CAST(JSON_VALUE(data, '$.temperature') AS FLOAT64) AS temperature,
  SAFE_CAST(JSON_VALUE(data, '$.humidity') AS FLOAT64)    AS humidity,
  JSON_VALUE(data, '$.deviceId')                          AS deviceId,
  JSON_VALUE(data, '$.createdAt')                         AS createdAt_raw,
  operation,
  timestamp
FROM
  `rawdata_table_name`
WHERE
  operation IN ('CREATE', 'UPDATE')  -- 삭제 이벤트 제외
  AND JSON_VALUE(data, '$.deviceId') IS NOT NULL;