From f49ddfb148b9ac9e12a368999c4e7e3b6a7ed53b Mon Sep 17 00:00:00 2001 From: nasseeder1 <> Date: Sat, 17 Sep 2016 19:11:20 +0000 Subject: [PATCH] 93_DbRep: new attr readingPreventFromDel to prevent readings from deletion when a new operation starts git-svn-id: https://svn.fhem.de/fhem/trunk@12164 2b470e98-0d58-463d-a4d8-8e2adae1ed80 --- fhem/CHANGED | 2 + fhem/FHEM/93_DbRep.pm | 157 ++++++++++++++++++++++++++---------------- 2 files changed, 98 insertions(+), 61 deletions(-) diff --git a/fhem/CHANGED b/fhem/CHANGED index fa57d4280..0177b437d 100644 --- a/fhem/CHANGED +++ b/fhem/CHANGED @@ -1,5 +1,7 @@ # Add changes at the top of the list. Keep it in ASCII, and 80-char wide. # Do not insert empty lines here, update check depends on it. + - feature: 93_DbRep: new attr readingPreventFromDel to prevent readings from + deletion when a new operation starts - change: 49_SSCam: attr simu_SVSversion changed, added 407 errorcode msg, external recording changed for SVS 7.2 - bugfix: 73_ElectricityCalculator: get/set list per device and not global diff --git a/fhem/FHEM/93_DbRep.pm b/fhem/FHEM/93_DbRep.pm index d58ecf78a..18fb86f52 100644 --- a/fhem/FHEM/93_DbRep.pm +++ b/fhem/FHEM/93_DbRep.pm @@ -37,6 +37,8 @@ ########################################################################################################### # Versions History: # +# 3.8 16.09.2016 new attr readingPreventFromDel to prevent readings from deletion +# when a new operation starts # 3.7.3 11.09.2016 changed format of diffValue-reading if no value was selected # 3.7.2 04.09.2016 problem in diffValue fixed if if no value was selected # 3.7.1 31.08.2016 Reading "errortext" added, commandref continued, exportToFile changed, @@ -145,6 +147,7 @@ sub DbRep_Initialize($) { "reading ". "allowDeletion:1,0 ". "readingNameMap ". + "readingPreventFromDel ". "device ". "expimpfile ". "aggregation:hour,day,week,month,no ". @@ -292,13 +295,13 @@ sub DbRep_Set($@) { } } - $hash->{helper}{I_TIMESTAMP} = $i_timestamp; - $hash->{helper}{I_DEVICE} = $i_device; - $hash->{helper}{I_READING} = $i_reading; - $hash->{helper}{I_VALUE} = $i_value; - $hash->{helper}{I_UNIT} = $i_unit; - $hash->{helper}{I_TYPE} = my $i_type = "manual"; - $hash->{helper}{I_EVENT} = my $i_event = "manual"; + $hash->{HELPER}{I_TIMESTAMP} = $i_timestamp; + $hash->{HELPER}{I_DEVICE} = $i_device; + $hash->{HELPER}{I_READING} = $i_reading; + $hash->{HELPER}{I_VALUE} = $i_value; + $hash->{HELPER}{I_UNIT} = $i_unit; + $hash->{HELPER}{I_TYPE} = my $i_type = "manual"; + $hash->{HELPER}{I_EVENT} = my $i_event = "manual"; } else { return "Data to insert to table 'history' are needed like this pattern: 'Date,Time,Value,[Unit]'. \"Unit\" is optional. Spaces are not allowed !"; @@ -353,6 +356,15 @@ sub DbRep_Attr($$$$) { } } + + if ($aName eq "readingPreventFromDel") { + if($cmd eq "set") { + if($aVal =~ / /) {return "Usage of $aName is wrong. Use a comma separated list of readings which are should prevent from deletion when a new selection starts.";} + $hash->{HELPER}{RDPFDEL} = $aVal; + } else { + delete $hash->{HELPER}{RDPFDEL} if($hash->{HELPER}{RDPFDEL}); + } + } if ($cmd eq "set") { if ($aName eq "timestamp_begin" || $aName eq "timestamp_end") { @@ -450,7 +462,7 @@ sub DbRep_Undef($$) { my $dbh = $hash->{DBH}; $dbh->disconnect() if(defined($dbh)); - BlockingKill($hash->{helper}{RUNNING_PID}) if (exists($hash->{helper}{RUNNING_PID})); + BlockingKill($hash->{HELPER}{RUNNING_PID}) if (exists($hash->{HELPER}{RUNNING_PID})); return undef; } @@ -537,13 +549,30 @@ sub sqlexec($$) { # $dbh->disconnect; #} - if (exists($hash->{helper}{RUNNING_PID})) { - Log3 ($name, 3, "DbRep $name - Warning: old process $hash->{helper}{RUNNING_PID}{pid} will be killed now to start a new BlockingCall"); - BlockingKill($hash->{helper}{RUNNING_PID}); + if (exists($hash->{HELPER}{RUNNING_PID})) { + Log3 ($name, 3, "DbRep $name - Warning: old process $hash->{HELPER}{RUNNING_PID}{pid} will be killed now to start a new BlockingCall"); + BlockingKill($hash->{HELPER}{RUNNING_PID}); } - # alte Readings löschen - delete $defs{$name}{READINGS}; + # alte Readings löschen die nicht in der Ausnahmeliste (Attr readingPreventFromDel) stehen + my @rdpfdel = split(",", $hash->{HELPER}{RDPFDEL}) if($hash->{HELPER}{RDPFDEL}); + if (@rdpfdel) { + my @allrds = keys($defs{$name}{READINGS}); + foreach my $key(@allrds) { + # Log3 ($name, 3, "DbRep $name - Reading Schlüssel: $key"); + my $dodel = 1; + foreach my $rdpfdel(@rdpfdel) { + if($key =~ /$rdpfdel/) { + $dodel = 0; + } + } + if($dodel) { + delete($defs{$name}{READINGS}{$key}); + } + } + } else { + delete $defs{$name}{READINGS}; + } readingsSingleUpdate($hash, "state", "running", 1); @@ -677,40 +706,40 @@ $hash->{HELPER}{CV} = \%cv; } if ($opt eq "sum") { - $hash->{helper}{RUNNING_PID} = BlockingCall("sumval_DoParse", "$name§$device§$reading§$ts", "sumval_ParseDone", $to, "ParseAborted", $hash); + $hash->{HELPER}{RUNNING_PID} = BlockingCall("sumval_DoParse", "$name§$device§$reading§$ts", "sumval_ParseDone", $to, "ParseAborted", $hash); } elsif ($opt eq "count") { - $hash->{helper}{RUNNING_PID} = BlockingCall("count_DoParse", "$name§$device§$reading§$ts", "count_ParseDone", $to, "ParseAborted", $hash); + $hash->{HELPER}{RUNNING_PID} = BlockingCall("count_DoParse", "$name§$device§$reading§$ts", "count_ParseDone", $to, "ParseAborted", $hash); } elsif ($opt eq "average") { - $hash->{helper}{RUNNING_PID} = BlockingCall("averval_DoParse", "$name§$device§$reading§$ts", "averval_ParseDone", $to, "ParseAborted", $hash); + $hash->{HELPER}{RUNNING_PID} = BlockingCall("averval_DoParse", "$name§$device§$reading§$ts", "averval_ParseDone", $to, "ParseAborted", $hash); } elsif ($opt eq "fetchrows") { $runtime_string_first = defined($epoch_seconds_begin) ? strftime "%Y-%m-%d %H:%M:%S", localtime($epoch_seconds_begin) : "1970-01-01 01:00:00"; $runtime_string_next = strftime "%Y-%m-%d %H:%M:%S", localtime($epoch_seconds_end); - $hash->{helper}{RUNNING_PID} = BlockingCall("fetchrows_DoParse", "$name|$device|$reading|$runtime_string_first|$runtime_string_next", "fetchrows_ParseDone", $to, "ParseAborted", $hash); + $hash->{HELPER}{RUNNING_PID} = BlockingCall("fetchrows_DoParse", "$name|$device|$reading|$runtime_string_first|$runtime_string_next", "fetchrows_ParseDone", $to, "ParseAborted", $hash); } elsif ($opt eq "exportToFile") { $runtime_string_first = defined($epoch_seconds_begin) ? strftime "%Y-%m-%d %H:%M:%S", localtime($epoch_seconds_begin) : "1970-01-01 01:00:00"; $runtime_string_next = strftime "%Y-%m-%d %H:%M:%S", localtime($epoch_seconds_end); - $hash->{helper}{RUNNING_PID} = BlockingCall("expfile_DoParse", "$name|$device|$reading|$runtime_string_first|$runtime_string_next", "expfile_ParseDone", $to, "ParseAborted", $hash); + $hash->{HELPER}{RUNNING_PID} = BlockingCall("expfile_DoParse", "$name|$device|$reading|$runtime_string_first|$runtime_string_next", "expfile_ParseDone", $to, "ParseAborted", $hash); } elsif ($opt eq "max") { - $hash->{helper}{RUNNING_PID} = BlockingCall("maxval_DoParse", "$name§$device§$reading§$ts", "maxval_ParseDone", $to, "ParseAborted", $hash); + $hash->{HELPER}{RUNNING_PID} = BlockingCall("maxval_DoParse", "$name§$device§$reading§$ts", "maxval_ParseDone", $to, "ParseAborted", $hash); } elsif ($opt eq "del") { $runtime_string_first = AttrVal($hash->{NAME}, "timestamp_begin", undef) ? strftime "%Y-%m-%d %H:%M:%S", localtime($epoch_seconds_begin) : "1970-01-01 01:00:00"; $runtime_string_next = strftime "%Y-%m-%d %H:%M:%S", localtime($epoch_seconds_end); - $hash->{helper}{RUNNING_PID} = BlockingCall("del_DoParse", "$name|$device|$reading|$runtime_string_first|$runtime_string_next", "del_ParseDone", $to, "ParseAborted", $hash); + $hash->{HELPER}{RUNNING_PID} = BlockingCall("del_DoParse", "$name|$device|$reading|$runtime_string_first|$runtime_string_next", "del_ParseDone", $to, "ParseAborted", $hash); } elsif ($opt eq "diff") { - $hash->{helper}{RUNNING_PID} = BlockingCall("diffval_DoParse", "$name§$device§$reading§$ts", "diffval_ParseDone", $to, "ParseAborted", $hash); + $hash->{HELPER}{RUNNING_PID} = BlockingCall("diffval_DoParse", "$name§$device§$reading§$ts", "diffval_ParseDone", $to, "ParseAborted", $hash); } elsif ($opt eq "insert") { - $hash->{helper}{RUNNING_PID} = BlockingCall("insert_Push", "$name", "insert_Done", $to, "ParseAborted", $hash); + $hash->{HELPER}{RUNNING_PID} = BlockingCall("insert_Push", "$name", "insert_Done", $to, "ParseAborted", $hash); } @@ -829,7 +858,7 @@ sub averval_ParseDone($) { if ($err) { readingsSingleUpdate($hash, "errortext", $err, 1); readingsSingleUpdate($hash, "state", "error", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall averval_ParseDone finished"); return; } @@ -863,7 +892,7 @@ sub averval_ParseDone($) { readingsEndUpdate($hash, 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall averval_ParseDone finished"); return; @@ -982,7 +1011,7 @@ sub count_ParseDone($) { if ($err) { readingsSingleUpdate($hash, "errortext", $err, 1); readingsSingleUpdate($hash, "state", "error", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall count_ParseDone finished"); return; } @@ -1017,7 +1046,7 @@ sub count_ParseDone($) { readingsBulkUpdate($hash, "state", "done"); readingsEndUpdate($hash, 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall count_ParseDone finished"); return; @@ -1148,7 +1177,7 @@ sub maxval_ParseDone($) { if ($err) { readingsSingleUpdate($hash, "errortext", $err, 1); readingsSingleUpdate($hash, "state", "error", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall maxval_ParseDone finished"); return; } @@ -1172,7 +1201,7 @@ sub maxval_ParseDone($) { # Test auf $value = "numeric" if (!looks_like_number($value)) { readingsSingleUpdate($hash, "state", "error", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); $a[3] =~ s/\s+$//g; Log3 ($name, 2, "DbRep $name - ERROR - value isn't numeric in maxValue function. Faulty dataset was \nTIMESTAMP: $a[2] $a[3], DEVICE: $device, READING: $reading, VALUE: $value. \nLeaving ..."); Log3 ($name, 4, "DbRep $name -> BlockingCall maxval_ParseDone finished"); @@ -1233,7 +1262,7 @@ sub maxval_ParseDone($) { readingsBulkUpdate($hash, "state", "done"); readingsEndUpdate($hash, 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall maxval_ParseDone finished"); return; @@ -1363,7 +1392,7 @@ sub diffval_ParseDone($) { if ($err) { readingsSingleUpdate($hash, "errortext", $err, 1); readingsSingleUpdate($hash, "state", "error", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall diffval_ParseDone finished"); return; } @@ -1400,7 +1429,7 @@ sub diffval_ParseDone($) { $err = "Value isn't numeric. Faulty dataset was - TIMESTAMP: $timestamp, VALUE: $value"; readingsSingleUpdate($hash, "errortext", $err, 1); readingsSingleUpdate($hash, "state", "error", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall diffval_ParseDone finished"); return; } @@ -1463,7 +1492,7 @@ sub diffval_ParseDone($) { readingsBulkUpdate($hash, "state", "done"); readingsEndUpdate($hash, 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall diffval_ParseDone finished"); return; @@ -1582,7 +1611,7 @@ sub sumval_ParseDone($) { if ($err) { readingsSingleUpdate($hash, "errortext", $err, 1); readingsSingleUpdate($hash, "state", "error", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall sumval_ParseDone finished"); return; } @@ -1615,7 +1644,7 @@ sub sumval_ParseDone($) { readingsBulkUpdate($hash, "state", "done"); readingsEndUpdate($hash, 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall sumval_ParseDone finished"); return; @@ -1709,7 +1738,7 @@ sub del_ParseDone($) { if ($err) { readingsSingleUpdate($hash, "errortext", $err, 1); readingsSingleUpdate($hash, "state", "error", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall del_ParseDone finished"); return; } @@ -1735,7 +1764,7 @@ sub del_ParseDone($) { readingsBulkUpdate($hash, "state", "done"); readingsEndUpdate($hash, 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall del_ParseDone finished"); return; @@ -1767,13 +1796,13 @@ sub insert_Push($) { return "$name|''|''|$err"; } - my $i_timestamp = $hash->{helper}{I_TIMESTAMP}; - my $i_device = $hash->{helper}{I_DEVICE}; - my $i_type = $hash->{helper}{I_TYPE}; - my $i_event = $hash->{helper}{I_EVENT}; - my $i_reading = $hash->{helper}{I_READING}; - my $i_value = $hash->{helper}{I_VALUE}; - my $i_unit = $hash->{helper}{I_UNIT} ? $hash->{helper}{I_UNIT} : " "; + my $i_timestamp = $hash->{HELPER}{I_TIMESTAMP}; + my $i_device = $hash->{HELPER}{I_DEVICE}; + my $i_type = $hash->{HELPER}{I_TYPE}; + my $i_event = $hash->{HELPER}{I_EVENT}; + my $i_reading = $hash->{HELPER}{I_READING}; + my $i_value = $hash->{HELPER}{I_VALUE}; + my $i_unit = $hash->{HELPER}{I_UNIT} ? $hash->{HELPER}{I_UNIT} : " "; # SQL zusammenstellen für DB-Operation @@ -1824,18 +1853,18 @@ sub insert_Done($) { Log3 ($name, 4, "DbRep $name -> Start BlockingCall insert_Done"); - my $i_timestamp = delete $hash->{helper}{I_TIMESTAMP}; - my $i_device = delete $hash->{helper}{I_DEVICE}; - my $i_type = delete $hash->{helper}{I_TYPE}; - my $i_event = delete $hash->{helper}{I_EVENT}; - my $i_reading = delete $hash->{helper}{I_READING}; - my $i_value = delete $hash->{helper}{I_VALUE}; - my $i_unit = delete $hash->{helper}{I_UNIT}; + my $i_timestamp = delete $hash->{HELPER}{I_TIMESTAMP}; + my $i_device = delete $hash->{HELPER}{I_DEVICE}; + my $i_type = delete $hash->{HELPER}{I_TYPE}; + my $i_event = delete $hash->{HELPER}{I_EVENT}; + my $i_reading = delete $hash->{HELPER}{I_READING}; + my $i_value = delete $hash->{HELPER}{I_VALUE}; + my $i_unit = delete $hash->{HELPER}{I_UNIT}; if ($err) { readingsSingleUpdate($hash, "errortext", $err, 1); readingsSingleUpdate($hash, "state", "error", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall insert_Done finished"); return; } @@ -1849,7 +1878,7 @@ sub insert_Done($) { Log3 ($name, 5, "DbRep $name - Inserted into database $hash->{dbloghash}{NAME} table 'history': Timestamp: $i_timestamp, Device: $i_device, Type: $i_type, Event: $i_event, Reading: $i_reading, Value: $i_value, Unit: $i_unit"); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall insert_Done finished"); return; @@ -1952,7 +1981,7 @@ sub fetchrows_ParseDone($) { if ($err) { readingsSingleUpdate($hash, "errortext", $err, 1); readingsSingleUpdate($hash, "state", "error", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall fetchrows_ParseDone finished"); return; } @@ -1985,7 +2014,7 @@ sub fetchrows_ParseDone($) { readingsBulkUpdate($hash, "state", "done"); readingsEndUpdate($hash, 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall fetchrows_ParseDone finished"); return; @@ -2094,7 +2123,7 @@ sub expfile_ParseDone($) { if ($err) { readingsSingleUpdate($hash, "errortext", $err, 1); readingsSingleUpdate($hash, "state", "error", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall expfile_ParseDone finished"); return; } @@ -2121,7 +2150,7 @@ sub expfile_ParseDone($) { readingsEndUpdate($hash, 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); Log3 ($name, 4, "DbRep $name -> BlockingCall expfile_ParseDone finished"); return; @@ -2134,9 +2163,9 @@ sub ParseAborted($) { my ($hash) = @_; my $name = $hash->{NAME}; - Log3 ($name, 1, "DbRep $name -> BlockingCall $hash->{helper}{RUNNING_PID}{fn} timed out"); + Log3 ($name, 1, "DbRep $name -> BlockingCall $hash->{HELPER}{RUNNING_PID}{fn} timed out"); readingsSingleUpdate($hash, "state", "timeout", 1); - delete($hash->{helper}{RUNNING_PID}); + delete($hash->{HELPER}{RUNNING_PID}); } @@ -2171,7 +2200,7 @@ sub collaggstr($$$$) { # keine Aggregation (all between timestamps) if ($aggregation eq "no") { - $runtime_string = "all between timestamps"; # für Readingname + $runtime_string = "all_between_timestamps"; # für Readingname $runtime_string_first = strftime "%Y-%m-%d %H:%M:%S", localtime($runtime); $runtime_string_next = strftime "%Y-%m-%d %H:%M:%S", localtime($epoch_seconds_end); $ll = 1; @@ -2327,7 +2356,9 @@ return ($runtime,$runtime_string,$runtime_string_first,$runtime_string_next,$ll) Readings will be filled. The data selection will been done by declaration of device, reading and the time settings of selection-begin and selection-end.

All database operations are implemented nonblocking. Optional the execution time of SQL-statements in background can also be determined and provided as reading. - (refer to attributes).

+ (refer to attributes).
+ All existing readings will be deleted when a new operation starts. By attribute "readingPreventFromDel" a comma separated list of readings which are should prevent + from deletion can be provided.

Currently the following functions are provided:

@@ -2452,6 +2483,7 @@ return ($runtime,$runtime_string,$runtime_string_first,$runtime_string_next,$ll)
  • expimpfile - Path/filename for data export

  • reading - selection of a particular reading

  • readingNameMap - the name of the analyzed reading can be overwritten for output

    • +
  • readingPreventFromDel - comma separated list of readings which are should prevent from deletion when a new operation starts

  • showproctime - if set, the reading "sql_processing_time" shows the required execution time (in seconds) for the sql-requests. This is not calculated for a single sql-statement, but the summary of all sql-statements necessara for within an executed DbRep-function in background.

  • timestamp_begin - begin of data selection (*)

  • timestamp_end - end of data selection. If not set the current date/time combination will be used. (*)

    • @@ -2511,7 +2543,9 @@ return ($runtime,$runtime_string,$runtime_string_first,$runtime_string_next,$ll) die Zeitgrenzen für Auswertungsbeginn bzw. Auswertungsende.

    Alle Datenbankoperationen werden nichtblockierend ausgeführt. Die Ausführungszeit der SQL-Hintergrundoperationen kann optional ebenfalls als Reading bereitgestellt - werden (siehe Attribute).

    + werden (siehe Attribute).
    + Alle vorhandenen Readings werden vor einer neuen Operation gelöscht. Durch das Attribut "readingPreventFromDel" kann eine Komma separierte Liste von Readings + angegeben werden die nicht gelöscht werden sollen.

    Zur Zeit werden folgende Operationen unterstützt:

    @@ -2635,6 +2669,7 @@ return ($runtime,$runtime_string,$runtime_string_first,$runtime_string_next,$ll)
  • expimpfile - Pfad/Dateiname für Datenexport

  • reading - Abgrenzung der DB-Selektionen auf ein bestimmtes Reading

  • readingNameMap - der Name des ausgewerteten Readings wird mit diesem String für die Anzeige überschrieben

    • +
  • readingPreventFromDel - Komma separierte Liste von Readings die vor einer neuen Operation nicht gelöscht werden sollen

  • showproctime - wenn gesetzt, zeigt das Reading "sql_processing_time" die benötigte Abarbeitungszeit (in Sekunden) für die SQL-Ausführung der durchgeführten Funktion. Dabei wird nicht ein einzelnes SQl-Statement, sondern die Summe aller notwendigen SQL-Abfragen innerhalb der jeweiligen Funktion betrachtet.

  • timestamp_begin - der zeitliche Beginn für die Datenselektion (*)

  • timestamp_end - das zeitliche Ende für die Datenselektion. Wenn nicht gesetzt wird immer die aktuelle Datum/Zeit-Kombi für das Ende der Selektion eingesetzt. (*)