admin/readin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Einige Environment-Variablen angepasst

Browse Source
This commit is contained in:
Reinhard X. Fürst
2023-10-26 10:25:43 +00:00
parent 8bda972061
commit 45b56415b1
4 changed files with 28 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
docs/Readme.md Normal file
View File

@@ -0,0 +1,6 @@
# Installation der Container
rxf 2023-10-25
#### Dateien
#### Aufrufe

9
influx_post.js
View File

@@ -5,11 +5,11 @@ import { logit, logerror } from './logit.js'
import { DateTime } from 'luxon' import { DateTime } from 'luxon'
import { statistics } from'./readdata.js' import { statistics } from'./readdata.js'
let DEVELOP = process.env.DEVELOP || 'false'
let INFLUXHOST = process.env.INFLUXHOST || "localhost" let INFLUXHOST = process.env.INFLUXHOST || "localhost"
let INFLUXPORT = process.env.INFLUXPORT || 8086 let INFLUXPORT = process.env.INFLUXPORT || 8086
let INFLUXTOKEN = process.env.INFLUXTOKEN || let INFLUXTOKEN = process.env.INFLUXTOKEN || 'empty'
"xuxTjvV7L3Mlr9diG36gMxExP_SbFntuJkp9KYj2_Hnz5U9zbCo7wurdkQqDtKO0Zchr6wbS8kGNW1L5I2V9YQ=="
let INFLUXDATABUCKET = process.env.INFLUXDATABUCKET || "sensor_data" let INFLUXDATABUCKET = process.env.INFLUXDATABUCKET || "sensor_data"
let INFLUXORG = process.env.INFLUXORG || "citysensor" let INFLUXORG = process.env.INFLUXORG || "citysensor"
@@ -46,7 +46,10 @@ export const influxRead = async (query) => {
export const influxWrite = async (data) => { export const influxWrite = async (data) => {
let start = DateTime.now() let start = DateTime.now()
let ret let ret
// logit(INFLUXURL_WRITE) logit(INFLUXURL_WRITE)
if (DEVELOP === 'true') {
logit(`Token: ${INFLUXTOKEN}`)
}
try { try {
ret = await axios({ ret = await axios({
method: 'post', method: 'post',

18
mongo.js
View File

@@ -5,7 +5,7 @@ import { logit, logerror } from './logit.js'
import { statistics } from './readdata.js' import { statistics } from './readdata.js'
import { DateTime } from 'luxon' import { DateTime } from 'luxon'
// const nodemailer = require('nodemailer'); let DEVELOP = process.env.DEVELOP || 'false'
let MONGOHOST = process.env.MONGOHOST || 'localhost' let MONGOHOST = process.env.MONGOHOST || 'localhost'
let MONGOPORT = process.env.MONGOPORT || 27017 let MONGOPORT = process.env.MONGOPORT || 27017
@@ -16,10 +16,10 @@ let MONGOBASE = process.env.MONGOBASE || 'allsensors'
let MONGO_URL = 'mongodb://' + MONGOHOST + ':' + MONGOPORT; // URL to mongo database let MONGO_URL = 'mongodb://' + MONGOHOST + ':' + MONGOPORT; // URL to mongo database
if (MONGOAUTH == 'true') { if (MONGOAUTH == 'true') {
MONGO_URL = 'mongodb://' + MONGOUSRP + '@' + MONGOHOST + ':' + MONGOPORT + '/?authSource=' + MONGOBASE; // URL to mongo database MONGO_URL = 'mongodb://' + MONGOUSRP + '@' + MONGOHOST + ':' + MONGOPORT + '/?authSource=admin'; // URL to mongo database
} }
export const property_coll = 'pptest' export const property_coll = 'properties'
const addandshowstatistics = (client, text, field, start) => { const addandshowstatistics = (client, text, field, start) => {
statistics[field] = DateTime.now().diff(start, ['seconds']).toObject().seconds statistics[field] = DateTime.now().diff(start, ['seconds']).toObject().seconds
@@ -28,9 +28,17 @@ const addandshowstatistics = (client, text, field, start) => {
export const connectMongo = async () => { export const connectMongo = async () => {
try { try {
logit(`Try to connect to ${MONGO_URL}`) if(DEVELOP === 'true') {
logit(`Try to connect to ${MONGO_URL}`)
} else {
logit(`Try to connect to ${'mongodb://' + MONGOHOST + ':' + MONGOPORT}`)
}
let client = await MongoClient.connect(MONGO_URL, { useNewUrlParser: true, useUnifiedTopology: true }) let client = await MongoClient.connect(MONGO_URL, { useNewUrlParser: true, useUnifiedTopology: true })
logit(`Mongodbase connected to ${MONGO_URL}`) if ( DEVELOP === 'true') {
logit(`Mongodbase connected to ${MONGO_URL}`)
} else {
logit('Mongodbase connected')
}
return client return client
} }
catch (error) { catch (error) {

6
readdata.js
View File

@@ -3,16 +3,16 @@ import * as fs from 'fs'
import { logit, logerror} from'./logit.js' import { logit, logerror} from'./logit.js'
import { DateTime } from 'luxon' import { DateTime } from 'luxon'
const API_URL = 'https://api.sensor.community/static/v1/data.json'; // URL to API on 'luftdaten.info' const API_URL = 'https://api.sensor.community/static/v1/data.json'; // URL to API on 'luftdaten.info'
const SAVE_NAME = 'data/aktdata.json'; // filename for actual data const SAVE_NAME = '/data/aktdata.json'; // filename for actual data
let LIVE = (process.env.LIVE == "true") || true let LIVE = process.env.LIVE || 'true'
export let statistics = {}; export let statistics = {};
export const doReadfromAPI = async () => { export const doReadfromAPI = async () => {
logit(`LIVE = ${LIVE}`) logit(`LIVE = ${LIVE}`)
let start = DateTime.now() let start = DateTime.now()
let data = [] let data = []
if (LIVE) { if (LIVE === 'true') {
logit(`Start Reading from API`) logit(`Start Reading from API`)
let body let body
for(let count = 1; count <= 3; count++) { for(let count = 1; count <= 3; count++) {