alex9ufo 聰明人求知心切

2023年7月28日星期五

使用 ChatGPT 寫一node-red 程式可以擷取台灣地區的氣象

使用 ChatGPT 寫一node-red 程式可以擷取台灣地區的氣象

User

寫一node-red 程式可以擷取台灣地區的氣象

ChatGPT

很抱歉，作為一個文字模型，我無法直接在Node-RED中運行程式碼，但我可以提供給你一個範例，讓你在Node-RED中擷取台灣地區的氣象資料。在這個範例中，我們將使用「中央氣象局開放資料平台」來取得氣象資料。

首先，確保你已經安裝了Node-RED並運行成功。然後，遵循以下步驟：

安裝 node-red-contrib-http-request 套件：在Node-RED的左側功能面板中，點擊「管理套件」，搜尋「node-red-contrib-http-request」，然後按照指示安裝。

在Node-RED的工作區中建立以下流程：

css

Copy code

[Inject] -> [HTTP Request] -> [Debug]

配置Inject節點：將Inject節點設置為單次觸發（例如，「單個」），以便手動觸發資料擷取。

配置HTTP Request節點：點擊這個節點，將其設置為GET請求，並在URL欄位中輸入以下API網址，用於獲取台灣地區的氣象資料：

ruby

Copy code

https://opendata.cwb.gov.tw/api/v1/rest/datastore/O-A0003-001?Authorization=你的API金鑰&elementName=TEMP,HUMD,PRES,Weather

這個URL包含了「中央氣象局開放資料平台」提供的「臺灣地區測站-現在天氣觀測報告」的API網址，並指定了要獲取的元素，例如溫度（TEMP）、濕度（HUMD）、氣壓（PRES）和天氣狀況（Weather）。請確保替換「你的API金鑰」為你註冊API時收到的實際API金鑰。

配置Debug節點：將Debug節點設置為「完整的訊息物件」，以便查看獲取的氣象資料。

點擊右上角的「Deploy」按鈕以儲存和部署你的流程。

當你按下Inject節點時，HTTP Request節點將觸發API請求，並從中央氣象局獲取台灣地區的氣象資料。這些資料將顯示在Debug節點的輸出中。

請注意，你需要註冊並取得中央氣象局開放資料平台的API金鑰，以便在URL中使用。此外，中央氣象局開放資料平台的API使用可能會有限制和配額，請參考其官方文件以瞭解詳細資訊。

這只是一個簡單的範例，你可以根據需求進一步處理資料，將它顯示在網頁上或儲存到資料庫中。希望這可以幫助到你入門擷取台灣地區的氣象資料。

User

請繼續

ChatGPT

當然，我可以為你提供更多關於Node-RED程式的資訊。接下來，我將展示如何將獲取的氣象資料進一步處理並在Node-RED中顯示出來。

解析API回應：

當API回應返回後，我們需要將其解析為可讀取的格式。在HTTP Request節點的設定中，將Response選項設置為a parsed JSON object，這樣就可以自動將API回應轉換為JavaScript物件。這使得我們可以更輕鬆地處理資料。

處理氣象資料：

使用Change節點（在左側功能面板中的"function"類別下）來處理氣象資料。這個節點讓你可以使用JavaScript進行資料的轉換和過濾。例如，你可以從API回應物件中提取出溫度、濕度和天氣狀況等資料。

以下是一個處理資料的範例JavaScript程式碼：

Copy code

// 範例程式碼

msg.payload = {

temperature: msg.payload.records.location[0].weatherElement[0].elementValue,

humidity: msg.payload.records.location[0].weatherElement[1].elementValue,

pressure: msg.payload.records.location[0].weatherElement[2].elementValue,

weather: msg.payload.records.location[0].weatherElement[3].elementValue

};

return msg;

這個程式碼會提取API回應物件中的相關資料並將它們存儲在msg.payload物件中，以便後續使用。

顯示氣象資料：

使用Debug節點來檢查處理後的氣象資料，或者使用Dashboard節點（如果你已經安裝了Node-RED Dashboard套件）來建立一個儀表板，將氣象資料以圖形或數值的形式呈現。你可以使用Dashboard節點中的各種元件（例如Gauge、Chart、Text等）來自定義資料的顯示方式。

錯誤處理：

記得在處理API回應時，要考慮到可能的錯誤情況，例如無法連接API伺服器或API回應錯誤等。你可以使用Try-Catch節點或Function節點中的JavaScript程式碼來捕獲和處理這些錯誤。

總結：

以上提供的是一個簡單的Node-RED範例，用於擷取台灣地區的氣象資料。你可以根據需求進一步擴展和自定義你的程式，例如加入資料庫存儲、定時更新等功能。希望這些資訊能對你有所幫助！

User

請將上面的溫度（TEMP）、濕度（HUMD）、氣壓（PRES）和天氣狀況（Weather）利用 Sqlite資料庫儲存起來欄位有日期時間溫度濕度氣壓天氣狀況備註等7個欄位

ChatGPT

當將氣象資料儲存到SQLite資料庫中時，你可以使用Node-RED中的node-red-node-sqlite套件來實現。請確保已經在Node-RED中安裝了這個套件。

以下是將氣象資料儲存到SQLite資料庫的流程：

設定SQLite資料庫連接：

在Node-RED的左側功能面板中，找到「sqlite」類別，將sqlite節點拖放到工作區中。點擊節點進行設定。你需要提供SQLite資料庫的名稱和位置。選擇一個合適的路徑和資料庫名稱，例如/path/to/weather_data.db。

解析API回應：

與之前相同，使用HTTP Request節點和Change節點來解析API回應，提取溫度、濕度、氣壓和天氣狀況等資料。

格式化日期和時間：

在將資料存儲到資料庫之前，我們需要準備日期和時間的欄位。你可以使用Function節點來添加當前的日期和時間到資料。

Copy code

var currentDate = new Date();

msg.date = currentDate.toISOString().split('T')[0];

msg.time = currentDate.toISOString().split('T')[1].split('.')[0];

return msg;

建立SQLite資料表：

在Node-RED的左側功能面板中，找到「sqlite」類別，將sqlite節點拖放到工作區中。點擊節點進行設定，選擇「execute」模式。在Command欄位中輸入SQL語句來建立資料表。下面是一個建立資料表的SQL語句範例：

sql

Copy code

CREATE TABLE IF NOT EXISTS weather_data (

id INTEGER PRIMARY KEY AUTOINCREMENT,

date TEXT,

time TEXT,

temperature REAL,

humidity REAL,

pressure REAL,

weather TEXT,

note TEXT

);

插入資料到資料庫：

使用Function節點來準備要插入資料庫的資料，並使用SQLite節點進行插入。

Copy code

var sqliteData = {

date: msg.date,

time: msg.time,

temperature: msg.payload.temperature,

humidity: msg.payload.humidity,

pressure: msg.payload.pressure,

weather: msg.payload.weather,

note: "這是一個備註範例。可以根據需求修改。"

};

msg.topic = "INSERT INTO weather_data (date, time, temperature, humidity, pressure, weather, note) VALUES ($date, $time, $temperature, $humidity, $pressure, $weather, $note)";

msg.payload = sqliteData;

return msg;

最後，使用SQLite節點進行SQL插入指令的執行。

點擊右上角的「Deploy」按鈕以儲存和部署你的流程。

這樣，每當你按下Inject節點，Node-RED將觸發API請求，獲取氣象資料，然後將它們儲存到SQLite資料庫中的weather_data表中。

請注意，上述程式碼僅供參考，你可能需要根據API回應的實際格式和SQLite資料表的需求進行調整。希望這可以幫助你將氣象資料儲存到SQLite資料庫中。

Node-Red程式

[{"id":"29524fb9ae25eac2","type":"inject","z":"be36ae0c358ba0e7","name":"","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":false,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":270,"y":100,"wires":[["67b10f612aeba21d"]]},{"id":"67b10f612aeba21d","type":"http request","z":"be36ae0c358ba0e7","name":"","method":"GET","ret":"obj","paytoqs":"ignore","url":"https://opendata.cwb.gov.tw/api/v1/rest/datastore/O-A0003-001?Authorization=CWB-40C225F2FF-1224-4250-B9D9-3735AAE17DBF&elementName=TEMP,HUMD,PRES,Weather","tls":"","persist":false,"proxy":"","insecureHTTPParser":false,"authType":"","senderr":false,"headers":[],"credentials":{},"x":460,"y":100,"wires":[["3a247ad8571a9d43","ebfcca1381b1cb9d"]]},{"id":"3a247ad8571a9d43","type":"debug","z":"be36ae0c358ba0e7","name":"debug 119","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","statusVal":"","statusType":"auto","x":710,"y":100,"wires":[]},{"id":"ebfcca1381b1cb9d","type":"function","z":"be36ae0c358ba0e7","name":"function 42","func":"// 範例程式碼\nmsg.payload = {\n temperature: msg.payload.records.location[0].weatherElement[0].elementValue,\n humidity: msg.payload.records.location[0].weatherElement[1].elementValue,\n pressure: msg.payload.records.location[0].weatherElement[2].elementValue,\n weather: msg.payload.records.location[0].weatherElement[3].elementValue\n};\nreturn msg;\n","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":610,"y":200,"wires":[["ed8ee569c17ccd6a"]]},{"id":"ed8ee569c17ccd6a","type":"debug","z":"be36ae0c358ba0e7","name":"debug 120","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","statusVal":"","statusType":"auto","x":830,"y":200,"wires":[]}]

2023年7月18日星期二

實驗 ESP32 + RFID (Create Mode 建立資料模式/ Query Mode查詢資料模式)

#include <WiFi.h>
#include <PubSubClient.h>
#include <SPI.h>
#include <MFRC522.h>
// GPIO 2 D1
#define LED 2
/* Wiring RFID RC522 module
=============================================================================
GND     = GND   3.3V    = 3.3V
The following table shows the typical pin layout used:
 *             MFRC522      ESP32     Arduino       Arduino   Arduino    Arduino          Arduino
 *             Reader/PCD             Uno/101       Mega      Nano v3    Leonardo/Micro   Pro Micro
 * Signal      Pin          Pin       Pin           Pin       Pin        Pin              Pin
 * -----------------------------------------------------------------------------------------
 * RST/Reset   RST          GPIO27    9             5         D9         RESET/ICSP-5     RST
 * SPI SS      SDA(SS)      GPIO5     10            53        D10        10               10
 * SPI MOSI    MOSI         GPIO23    11 / ICSP-4   51        D11        ICSP-4           16
 * SPI MISO    MISO         GPIO19    12 / ICSP-1   50        D12        ICSP-1           14
 * SPI SCK     SCK          GPIO18    13 / ICSP-3   52        D13        ICSP-3           15
 *
[1] (1, 2) Configurable, typically defined as RST_PIN in sketch/program.
[2] (1, 2) Configurable, typically defined as SS_PIN in sketch/program.
[3] The SDA pin might be labeled SS on some/older MFRC522 boards
=============================================================================
*/

#define SS_PIN  5  // ESP32 pin GIOP5 
#define RST_PIN 27 // ESP32 pin GIOP27 


// WiFi
const char *ssid = "alex9ufo"; // Enter your Wi-Fi name
const char *password = "alex9981";  // Enter Wi-Fi password

// MQTT Broker
const char *mqtt_broker = "broker.mqtt-dashboard.com";
const char *topic1 = "alex9ufo/esp32/led";
const char *topic2 = "alex9ufo/esp32/RFID";
const char *topic = "alex9ufo/esp32/Starting";


const char *mqtt_username = "alex9ufo";
const char *mqtt_password = "public";
const int mqtt_port = 1883;

bool ledState = false;
bool atwork = false;

WiFiClient espClient;
PubSubClient client(espClient);
MFRC522 rfid(SS_PIN, RST_PIN); // Create MFRC522 instance

long lastMsg = 0;
long lastMsg1= 0;

char msg[50];
String json = "";    
char jsonChar1[100];  //client.publish("alex9ufo/Esp32/RFID"
//===========================================================
String printHex(byte *buffer, byte bufferSize) {
      String id = "";
      for (byte i = 0; i < bufferSize; i++) {
        id += buffer[i] < 0x10 ? "0" : "";
        id += String(buffer[i], HEX);
      }
      return id;
    }
//===========================================================
void setup() {
    // Set software serial baud to 115200;
    Serial.begin(115200);
    delay(1000); // Delay for stability
    //======================================================
    // Connecting to a WiFi network
    WiFi.begin(ssid, password);
    while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.println("Connecting to WiFi...");
    }
    Serial.println("Connected to the WiFi network");

    // Setting LED pin as output
    pinMode(LED, OUTPUT);
    digitalWrite(LED, LOW);  // Turn off the LED initially
    //======================================================
    SPI.begin();           // Init SPI bus
    rfid.PCD_Init();    // Init MFRC522

    Serial.println(F("Ready!"));
    Serial.println(F("======================================================")); 
    Serial.println("Tap an RFID/NFC tag on the RFID-RC522 reader");


    // Connecting to an MQTT broker
    client.setServer(mqtt_broker, mqtt_port);
    client.setCallback(callback);
    while (!client.connected()) {
        String client_id = "esp32-client-";
        client_id += String(WiFi.macAddress());
        Serial.printf("The client %s connects to the public MQTT broker\n", client_id.c_str());
        if (client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {
            Serial.println("Public HiveMQ MQTT broker (broker.mqtt-dashboard.com) connected");
        } else {
            Serial.print("Failed with state ");
            Serial.print(client.state());
            delay(2000);
        }
    }

    // Publish and subscribe
    client.subscribe(topic1);
    client.publish(topic,"ESP32 at work");
}
//===========================================================
void callback(char *topic, byte *payload, unsigned int length) {
    Serial.print("Message arrived in topic: ");
    Serial.println(topic);
    Serial.print("Message: ");
    String message;
    for (int i = 0; i < length; i++) {
        message += (char) payload[i];  // Convert *byte to string
    }
    Serial.print(message);
    if (message == "on" && !ledState) {
        digitalWrite(LED, HIGH);  // Turn on the LED
        ledState = true;
    }
    if (message == "off" && ledState) {
        digitalWrite(LED, LOW); // Turn off the LED
        ledState = false;
    }
    Serial.println();
    Serial.println("-----------------------");
}
//===========================================================
void loop() {
    client.loop();
    delay(100); // Delay for a short period in each loop iteration
    long now = millis();
    long now1 = millis();
    if (now1 - lastMsg1 > 80000) {
        lastMsg1 = now1;
        if (atwork) {
            client.publish(topic,"ESP32 at work");
            atwork=false;
        } else {
            client.publish(topic,"             ");
            atwork=true;
        }
     }
     
    if (now - lastMsg > 5000) {
      Serial.println("Reading RFIF card");
      lastMsg = now;
      if (rfid.PICC_IsNewCardPresent()) { // new tag is available
        if (rfid.PICC_ReadCardSerial()) { // NUID has been readed
          MFRC522::PICC_Type piccType = rfid.PICC_GetType(rfid.uid.sak);
          Serial.print("RFID/NFC Tag Type: ");
          Serial.println(rfid.PICC_GetTypeName(piccType));

          // print UID in Serial Monitor in the hex format
          Serial.print("UID:");
          for (int i = 0; i < rfid.uid.size; i++) {
            Serial.print(rfid.uid.uidByte[i] < 0x10 ? " 0" : " ");
            Serial.print(rfid.uid.uidByte[i], HEX);
          }
          Serial.println();

          String json = printHex(rfid.uid.uidByte, rfid.uid.size);
          // Convert JSON string to character array
          json.toCharArray(jsonChar1, json.length()+1);
    
          if  (client.connected()) {
            Serial.print("Publish message: ");
            Serial.println(json);
            // Publish JSON character array to MQTT topic
            client.publish(topic2,jsonChar1);
          }     
          rfid.PICC_HaltA(); // halt PICC
          rfid.PCD_StopCrypto1(); // stop encryption on PCD
          
          
        }
      }
        
  }

}
//===========================================================

2023年7月14日星期五

實驗 ESP32 RFID + Node-Red 新增資料自動比對資料庫的資料 (比對模式: Query + Create)

#include <WiFi.h>
#include <PubSubClient.h>
#include <SPI.h>
#include <MFRC522.h>
// GPIO 2 D1
#define LED 2
/* Wiring RFID RC522 module
=============================================================================
GND     = GND   3.3V    = 3.3V
The following table shows the typical pin layout used:
 *             MFRC522      ESP32     Arduino       Arduino   Arduino    Arduino          Arduino
 *             Reader/PCD             Uno/101       Mega      Nano v3    Leonardo/Micro   Pro Micro
 * Signal      Pin          Pin       Pin           Pin       Pin        Pin              Pin
 * -----------------------------------------------------------------------------------------
 * RST/Reset   RST          GPIO27    9             5         D9         RESET/ICSP-5     RST
 * SPI SS      SDA(SS)      GPIO5     10            53        D10        10               10
 * SPI MOSI    MOSI         GPIO23    11 / ICSP-4   51        D11        ICSP-4           16
 * SPI MISO    MISO         GPIO19    12 / ICSP-1   50        D12        ICSP-1           14
 * SPI SCK     SCK          GPIO18    13 / ICSP-3   52        D13        ICSP-3           15
 *
[1] (1, 2) Configurable, typically defined as RST_PIN in sketch/program.
[2] (1, 2) Configurable, typically defined as SS_PIN in sketch/program.
[3] The SDA pin might be labeled SS on some/older MFRC522 boards
=============================================================================
*/

#define SS_PIN  5  // ESP32 pin GIOP5 
#define RST_PIN 27 // ESP32 pin GIOP27 


// WiFi
const char *ssid = "alex9ufo"; // Enter your Wi-Fi name
const char *password = "alex9981";  // Enter Wi-Fi password

// MQTT Broker
const char *mqtt_broker = "broker.mqtt-dashboard.com";
const char *topic1 = "alex9ufo/esp32/led";
const char *topic2 = "alex9ufo/esp32/RFID";

const char *mqtt_username = "alex9ufo";
const char *mqtt_password = "public";
const int mqtt_port = 1883;

bool ledState = false;

WiFiClient espClient;
PubSubClient client(espClient);
MFRC522 rfid(SS_PIN, RST_PIN); // Create MFRC522 instance

long lastMsg = 0;
char msg[50];
String json = "";    
char jsonChar1[100];  //client.publish("alex9ufo/Esp32/RFID"
//===========================================================
String printHex(byte *buffer, byte bufferSize) {
      String id = "";
      for (byte i = 0; i < bufferSize; i++) {
        id += buffer[i] < 0x10 ? "0" : "";
        id += String(buffer[i], HEX);
      }
      return id;
    }
//===========================================================
void setup() {
    // Set software serial baud to 115200;
    Serial.begin(115200);
    delay(1000); // Delay for stability
    //======================================================
    // Connecting to a WiFi network
    WiFi.begin(ssid, password);
    while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.println("Connecting to WiFi...");
    }
    Serial.println("Connected to the WiFi network");

    // Setting LED pin as output
    pinMode(LED, OUTPUT);
    digitalWrite(LED, LOW);  // Turn off the LED initially
    //======================================================
    SPI.begin();           // Init SPI bus
    rfid.PCD_Init();    // Init MFRC522

    Serial.println(F("Ready!"));
    Serial.println(F("======================================================")); 
    Serial.println("Tap an RFID/NFC tag on the RFID-RC522 reader");


    // Connecting to an MQTT broker
    client.setServer(mqtt_broker, mqtt_port);
    client.setCallback(callback);
    while (!client.connected()) {
        String client_id = "esp32-client-";
        client_id += String(WiFi.macAddress());
        Serial.printf("The client %s connects to the public MQTT broker\n", client_id.c_str());
        if (client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {
            Serial.println("Public HiveMQ MQTT broker (broker.mqtt-dashboard.com) connected");
        } else {
            Serial.print("Failed with state ");
            Serial.print(client.state());
            delay(2000);
        }
    }

    // Publish and subscribe
    client.subscribe(topic1);

}
//===========================================================
void callback(char *topic, byte *payload, unsigned int length) {
    Serial.print("Message arrived in topic: ");
    Serial.println(topic);
    Serial.print("Message: ");
    String message;
    for (int i = 0; i < length; i++) {
        message += (char) payload[i];  // Convert *byte to string
    }
    Serial.print(message);
    if (message == "on" && !ledState) {
        digitalWrite(LED, HIGH);  // Turn on the LED
        ledState = true;
    }
    if (message == "off" && ledState) {
        digitalWrite(LED, LOW); // Turn off the LED
        ledState = false;
    }
    Serial.println();
    Serial.println("-----------------------");
}
//===========================================================
void loop() {
    client.loop();
    delay(100); // Delay for a short period in each loop iteration
    long now = millis();
    if (now - lastMsg > 5000) {
      Serial.println("Reading RFIF card");
      lastMsg = now;
      if (rfid.PICC_IsNewCardPresent()) { // new tag is available
        if (rfid.PICC_ReadCardSerial()) { // NUID has been readed
          MFRC522::PICC_Type piccType = rfid.PICC_GetType(rfid.uid.sak);
          Serial.print("RFID/NFC Tag Type: ");
          Serial.println(rfid.PICC_GetTypeName(piccType));

          // print UID in Serial Monitor in the hex format
          Serial.print("UID:");
          for (int i = 0; i < rfid.uid.size; i++) {
            Serial.print(rfid.uid.uidByte[i] < 0x10 ? " 0" : " ");
            Serial.print(rfid.uid.uidByte[i], HEX);
          }
          Serial.println();

          String json = printHex(rfid.uid.uidByte, rfid.uid.size);
          // Convert JSON string to character array
          json.toCharArray(jsonChar1, json.length()+1);
    
          if  (client.connected()) {
            Serial.print("Publish message: ");
            Serial.println(json);
            // Publish JSON character array to MQTT topic
            client.publish(topic2,jsonChar1);
          }     
          rfid.PICC_HaltA(); // halt PICC
          rfid.PCD_StopCrypto1(); // stop encryption on PCD

        }
      }
        
  }

}
//===========================================================

訂閱：文章 (Atom)

2023年7月28日 星期五

使用 ChatGPT 寫一node-red 程式 可以擷取台灣地區的氣象

2023年7月18日 星期二

實驗 ESP32 + RFID (Create Mode 建立資料模式/ Query Mode查詢資料模式)

2023年7月14日 星期五

實驗 ESP32 RFID + Node-Red 新增資料 自動比對資料庫的資料 (比對模式: Query + Create)

Node-Red --> MQTT --> Fuxa

2023年7月28日星期五

使用 ChatGPT 寫一node-red 程式可以擷取台灣地區的氣象

2023年7月18日星期二

2023年7月14日星期五

實驗 ESP32 RFID + Node-Red 新增資料自動比對資料庫的資料 (比對模式: Query + Create)