[Node-RED] Exécuter Python sur l'environnement virtuel Anaconda à partir de Node-RED [Anaconda] [Python]

Chose que tu veux faire

• Exécutez Python à partir de Node-RED.

Fonctionnalité

-Utiliser Anaconda (pour faciliter l'environnement d'exécution Python)

• Tirez parti des nœuds Node-RED disponibles autant que possible (pour réduire les obstacles pour les débutants)

Image de ce que vous voulez faire

Environnement d'exécution

• OS:windows 10
• postgreSQL：9.6
• ANACONDA NAVIGATOR：1.9.12 --Python (sur l'environnement virtuel Anaconda): 3.7.7
• Node-RED：v1.0.4

objectif

1. Connectez-vous à postgreSQL depuis Node-RED et créez un fichier csv

Cinq nœuds sont requis. Rejoignez les nœuds suivants dans l'ordre suivant.

1. Nœud de fonction [Fonction]

• Objectif: assembler des instructions SQL --Utilisation: écrire une instruction SQL directement dans msg.payload

Image de description du nœud de fonction

msg.select = "SELECT  val"
msg.from = "FROM public.sensordata "
msg.where = "where sensor ='Capteur d'humidité'"
msg.orderBy = "order by datetime desc"
msg.limit = "limit 1000"

msg.payload = msg.select
msg.payload += " " + msg.from
msg.payload += " " + msg.where
msg.payload += " " + msg.orderBy
msg.payload += " " + msg.limit

return msg;

2. Nœud postgres [Stockage]

• Objectif: connectez-vous à postgreSQL et exécutez SQL --Utilisation: utilisation standard

3. [Fonction] nœud de conversion json vers csv

• Objectif: le nœud postgre retourne au format json, alors convertissez-le au format csv. --Utilisation: utilisation standard

4. Nœud de fonction [Function]

• Objet: spécifiez le nom du fichier --Utilisation: spécifiez le chemin complet du fichier csv dans msg.filename

Image de description du nœud de fonction

//Exemple) msg.rootpath = "C:\\temp\\conda"
//Exemple) msg.Obtenir l'horodatage du nœud d'injection
msg.filename = msg.rootpath + "\\indata\\" + msg.timestamp + ".csv";

return msg;

5. Nœud de fichier [Stockage]

• Objectif: créer un fichier csv --Utilisation: spécifiez *** vide *** pour le nom du fichier (s'il est vide, créez un fichier avec la valeur de réglage dans msg.filename)

2. Exécutez le fichier bat à partir de Node-RED

Deux nœuds sont nécessaires. Rejoignez les nœuds suivants dans l'ordre suivant.

point

--Spécifiez une commande + un argument dans *** msg.payload afin que la commande d'exécution puisse être spécifiée arbitrairement *** (Normalement, la commande est directement spécifiée dans le nœud exec, mais dans ce cas, elle ne peut pas être modifiée)
* Il semble que la commande soit exécutée avec la valeur de réglage de la commande du noeud exec + vide + msg.payload

1. Nœud de fonction [Fonction]

• Objectif: assembler la commande d'exécution --Usage: définit la commande à exécuter dans msg.payload

Image de description du nœud de fonction

//Chemin complet du fichier bat à exécuter Exemple)"C:\\temp\\conda\\ExecPython.bat"* Du fichier bat qui exécute le programme Python spécifié
msg.command = msg.execPythonCmd
//1er exemple d'argument)"test.py"* Nom de fichier du programme Python à exécuter
msg.arg_1 = msg.execPythonNm
//2ème argument Exemple) I au programme Python à exécuter/F (fichier d'entrée)
msg.arg_2 = "indata\\" + msg.timestamp + ".csv"
//3ème argument Exemple) I au programme Python à exécuter/F (fichier de sortie)
msg.arg_3 = "outdata\\" + msg.timestamp + ".csv"

msg.payload = msg.command + " " + msg.arg_1 + " " + msg.arg_2 + " " + msg.arg_3

return msg;

2. noeud d'exécution [Function] --Objectif: exécuter la commande --Utilisation: indiquez un *** vide pour la commande ***. *** La case à cocher pour msg.payload est cochée ***.

3. Activez l'environnement conda dans le fichier bat et exécutez le programme Python

ExecPython.bat

Déplacer vers le dossier d'exécution de rem
rem Exemple) C:\temp\Lorsque l'environnement d'exécution a été préparé sous conda
cd /d C:\temp\conda

Activer rem conda
call activateConda.bat

Exécutez rem Python
rem %1:Nom du fichier Python à exécuter
rem %1～7:Arguments à Python à exécuter
python %1 %2 %3 %4 %5 %6 %7

activateConda.bat

conda activate [Nom de l'environnement que vous souhaitez activer Exemple) base]

4. Spécifiez le fichier I / F pour le programme Python

test.py

import sys
#Obtenir des arguments
args = sys.argv

import pandas as pd
sensordata = pd.read_csv(args[1])

print(sensordata.describe())
sensordata.describe().to_csv(args[2], index=True)

Courir

Préparation 1) Préparation du dossier d'exécution

Les fichiers décrits en 3 et 4 sont stockés comme suit.

Préparation 2) Création de flux

Préparez le flux décrit en 1 et 2. Cela peut être plus facile à gérer si vous décrivez les informations requises pour l'exécution dans le nœud de fonction comme indiqué ci-dessous.

• Créez un flux à exécuter dans l'ordre "inject node-> execution condition setting-> 1-> 2"

Paramétrage des conditions d'exécution

msg.timestamp = msg.payload
msg.rootpath = "C:\\temp\\conda"
msg.execPythonCmd = "C:\\temp\\conda\\ExecPython.bat"
msg.execPythonNm = "test.py"
return msg;

Résultat d'exécution

Lire le fichier csv stocké dans le dossier indata et générer des statistiques simples dans le dossier outdata

en conclusion

«Node-RED» en tant que plateforme IoT, «Anaconda + Python + Jupyter Notebook» en tant que plateforme de science des données Je pense que cela peut être mentionné, mais je pense que DX progressera si ceux-ci sont connectés de manière transparente.