From 366ef31842337ff3e1267d94e05eeb8db3f6b811 Mon Sep 17 00:00:00 2001 From: nasseeder1 Date: Thu, 7 Dec 2017 16:44:17 +0000 Subject: [PATCH] 93_DbRep: V6.3.2 ,changelist to last version: - new command delSeqDoublets - add last command option to internal LASTCMD - add format d:xx h:xx m:xx s:xx for attributes timeDiffToNow, timeOlderThan - new attribute fetchRoute to switch asc,desc datafetch git-svn-id: https://svn.fhem.de/fhem/trunk@15565 2b470e98-0d58-463d-a4d8-8e2adae1ed80 --- fhem/CHANGED | 6 + fhem/FHEM/93_DbRep.pm | 722 +++++++++++++++++++++++++++++++++++++----- 2 files changed, 645 insertions(+), 83 deletions(-) diff --git a/fhem/CHANGED b/fhem/CHANGED index b63258810..e60934989 100644 --- a/fhem/CHANGED +++ b/fhem/CHANGED @@ -1,5 +1,11 @@ # 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. + - change: 93_DbRep: V6.3.2 ,changelist to last version: + - new command delSeqDoublets + - add last command option to internal LASTCMD + - add format d:xx h:xx m:xx s:xx for attributes + timeDiffToNow, timeOlderThan + - new attribute fetchRoute to switch asc,desc datafetch - change: HttpUtils: compression activated disable it with attr global httpcompress 0 - bugfix: 46_SmartPi: fix syntax error bug in Attribut Sub diff --git a/fhem/FHEM/93_DbRep.pm b/fhem/FHEM/93_DbRep.pm index 09e98873b..21d2bdeb9 100644 --- a/fhem/FHEM/93_DbRep.pm +++ b/fhem/FHEM/93_DbRep.pm @@ -37,6 +37,21 @@ ########################################################################################################################### # Versions History: # +# 6.3.2 05.12.2017 make direction of fetchrows switchable ASC <-> DESC by attribute fetchRoute +# 6.3.1 04.12.2017 fix DBD::mysql::st execute failed: Expression #1 of SELECT list is not in GROUP BY clause +# and contains nonaggregated column 'DEVELfhem.history.TIMESTAMP' which is not functionally +# dependent on columns in GROUP BY clause; this is incompatible with +# sql_mode=only_full_group_by +# Forum:https://forum.fhem.de/index.php/topic,65860.msg725595.html#msg725595 , +# fix currentfillup_Push PostgreSQL -> use $runtime_string_next as Timestring during current +# insert +# 6.3.0 04.12.2017 support addition format d:xx h:xx m:xx s:xx for attributes timeDiffToNow, timeOlderThan +# 6.2.3 04.12.2017 fix localtime(time); (current time deduction) in createTimeArray +# 6.2.2 01.12.2017 support all aggregations for delSeqDoublets, better output filesize when mysql dump finished +# 6.2.1 30.11.2017 support delSeqDoublets without device,reading is set and support device-devspec, reading list, +# minor fixes in delSeqDoublets +# 6.2.0 29.11.2017 enhanced command delSeqDoublets by "delete" +# 6.1.0 29.11.2017 new command delSeqDoublets (adviceRemain,adviceDelete), add Option to LASTCMD # 6.0.0 18.11.2017 FTP transfer dumpfile after dump, delete old dumpfiles within Blockingcall (avoid freezes) # commandref revised, minor fixes # 5.8.6 30.10.2017 don't limit attr reading, device if the attr contains a list @@ -247,7 +262,7 @@ use Encode qw(encode_utf8); sub DbRep_Main($$;$); -my $DbRepVersion = "6.0.0"; +my $DbRepVersion = "6.3.2"; my %dbrep_col = ("DEVICE" => 64, "TYPE" => 64, @@ -283,6 +298,7 @@ sub DbRep_Initialize($) { "executeBeforeDump ". "executeAfterDump ". "expimpfile ". + "fetchRoute:ascent,descent ". "ftpUse:1,0 ". "ftpUser ". "ftpUseSSL:1,0 ". @@ -388,6 +404,7 @@ sub DbRep_Set($@) { (($hash->{ROLE} ne "Agent")?"sumValue:noArg ":""). (($hash->{ROLE} ne "Agent")?"averageValue:noArg ":""). (($hash->{ROLE} ne "Agent")?"delEntries:noArg ":""). + (($hash->{ROLE} ne "Agent")?"delSeqDoublets:adviceRemain,adviceDelete,delete ":""). "deviceRename ". (($hash->{ROLE} ne "Agent")?"readingRename ":""). (($hash->{ROLE} ne "Agent")?"exportToFile:noArg ":""). @@ -407,9 +424,9 @@ sub DbRep_Set($@) { (($hash->{ROLE} ne "Agent")?"countEntries:history,current ":""); return if(IsDisabled($name)); - + if ($opt eq "dumpMySQL" && $hash->{ROLE} ne "Agent") { - $hash->{LASTCMD} = "$opt"; + $hash->{LASTCMD} = $prop?"$opt $prop":"$opt"; if ($prop eq "serverSide") { Log3 ($name, 3, "DbRep $name - ################################################################"); @@ -439,7 +456,7 @@ sub DbRep_Set($@) { } if ($opt eq "restoreMySQL" && $hash->{ROLE} ne "Agent") { - $hash->{LASTCMD} = "$opt"; + $hash->{LASTCMD} = $prop?"$opt $prop":"$opt"; Log3 ($name, 3, "DbRep $name - ################################################################"); Log3 ($name, 3, "DbRep $name - ### New database Restore/Recovery ###"); Log3 ($name, 3, "DbRep $name - ################################################################"); @@ -448,7 +465,7 @@ sub DbRep_Set($@) { } if ($opt =~ /optimizeTables|vacuum/ && $hash->{ROLE} ne "Agent") { - $hash->{LASTCMD} = "$opt"; + $hash->{LASTCMD} = $prop?"$opt $prop":"$opt"; Log3 ($name, 3, "DbRep $name - ################################################################"); Log3 ($name, 3, "DbRep $name - ### New optimize table / vacuum execution ###"); @@ -472,6 +489,12 @@ sub DbRep_Set($@) { Log3 ($name, 3, "DbRep $name -> running Dump has been canceled"); ReadingsSingleUpdateValue ($hash, "state", "Dump canceled", 1); + } elsif ($opt =~ m/delSeqDoublets/ && $hash->{ROLE} ne "Agent") { + if ($prop =~ /delete/ && !AttrVal($hash->{NAME}, "allowDeletion", 0)) { + return " Set attribute 'allowDeletion' if you want to allow deletion of any database entries. Use it with care !"; + } + DbRep_Main($hash,$opt,$prop); + } elsif ($opt eq "fetchrows" && $hash->{ROLE} ne "Agent") { my $table = $prop?$prop:"history"; DbRep_Main($hash,$opt,$table); @@ -586,7 +609,7 @@ sub DbRep_Set($@) { return "$setlist"; } -$hash->{LASTCMD} = "$opt"; +$hash->{LASTCMD} = $prop?"$opt $prop":"$opt"; return undef; } @@ -789,11 +812,20 @@ sub DbRep_Attr($$$$) { } if ($aName eq "timeDiffToNow") { - unless ($aVal =~ /^[0-9]+$/) { return "The Value of $aName is not valid. Use only figures 0-9 without decimal places. It's the time (in seconds) before current time used as start of selection. Refer to commandref !";} + unless ($aVal =~ /^[0-9]+$/ || $aVal =~ /^\s*[dhms]:([\d]+)\s*/ && $aVal !~ /.*,.*/ ) + { return "The Value of \"$aName\" isn't valid. Set simple seconds like \"86400\" or use form like \"d:10 h:6 m:12 s:20\". Refer to commandref !";} delete($attr{$name}{timestamp_begin}) if ($attr{$name}{timestamp_begin}); delete($attr{$name}{timestamp_end}) if ($attr{$name}{timestamp_end}); delete($attr{$name}{timeOlderThan}) if ($attr{$name}{timeOlderThan}); } + + if ($aName eq "timeOlderThan") { + unless ($aVal =~ /^[0-9]+$/ || $aVal =~ /^\s*[dhms]:([\d]+)\s*/ && $aVal !~ /.*,.*/ ) + { return "The Value of \"$aName\" isn't valid. Set simple seconds like \"86400\" or use form like \"d:10 h:6 m:12 s:20\". Refer to commandref !";} + delete($attr{$name}{timestamp_begin}) if ($attr{$name}{timestamp_begin}); + delete($attr{$name}{timestamp_end}) if ($attr{$name}{timestamp_end}); + delete($attr{$name}{timeDiffToNow}) if ($attr{$name}{timeDiffToNow}); + } if ($aName eq "dumpMemlimit" || $aName eq "dumpSpeed") { unless ($aVal =~ /^[0-9]+$/) { return "The Value of $aName is not valid. Use only figures 0-9 without decimal places.";} @@ -806,13 +838,6 @@ sub DbRep_Attr($$$$) { unless($aVal <= ($dml / 10)) {return "The Value of $aName mustn't be greater than 'dumpMemlimit / 10' ! ";} } } - - if ($aName eq "timeOlderThan") { - unless ($aVal =~ /^[0-9]+$/) { return "The Value of $aName is not valid. Use only figures 0-9 without decimal places. It's the time (in seconds) before current time used as end of selection. Refer to commandref !";} - delete($attr{$name}{timestamp_begin}) if ($attr{$name}{timestamp_begin}); - delete($attr{$name}{timestamp_end}) if ($attr{$name}{timestamp_end}); - delete($attr{$name}{timeDiffToNow}) if ($attr{$name}{timeDiffToNow}); - } if ($aName eq "ftpUse") { delete($attr{$name}{ftpUseSSL}); @@ -837,7 +862,6 @@ sub DbRep_Attr($$$$) { return undef; } - ################################################################################### # DbRep_Notify Eventverarbeitung ################################################################################### @@ -1060,6 +1084,9 @@ sub DbRep_Main($$;$) { Log3 ($name, 4, "DbRep $name - Command: $opt"); # zentrales Timestamp-Array und Zeitgrenzen bereitstellen + if($opt =~ /delSeqDoublets/) { + $aggregation = ($aggregation eq "no")?"day":$aggregation; # wenn Aggregation "no", für delSeqDoublets immer "day" setzen + } my ($epoch_seconds_begin,$epoch_seconds_end,$runtime_string_first,$runtime_string_next,$ts) = createTimeArray($hash,$aggregation,$opt); ##### Funktionsaufrufe ##### @@ -1080,6 +1107,10 @@ sub DbRep_Main($$;$) { $hash->{HELPER}{RUNNING_PID} = BlockingCall("fetchrows_DoParse", "$name|$table|$device|$reading|$runtime_string_first|$runtime_string_next", "fetchrows_ParseDone", $to, "ParseAborted", $hash); + } elsif ($opt =~ /delSeqDoublets/) { + my $cmd = $prop?$prop:"adviceRemain"; + $hash->{HELPER}{RUNNING_PID} = BlockingCall("delseqdoubl_DoParse", "$name§$cmd§$device§$reading§$ts", "delseqdoubl_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); @@ -1141,14 +1172,14 @@ sub createTimeArray($$$) { # year als Jahre seit 1900 # $mon als 0..11 # $time = timelocal( $sec, $min, $hour, $mday, $mon, $year ); - my ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime(); # Istzeit Ableitung - ############################################################################################### - # Auswertungszeit Beginn (String) - # dynamische Berechnung von Startdatum/zeit aus current_xxx_begin / previous_xxx_begin - # dynamische Berechnung von Endedatum/zeit aus current_xxx_end / previous_xxx_end - ############################################################################################### + my ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime(time); # Istzeit Ableitung my ($tsbegin,$tsend,$dim,$tsub,$tadd); my ($rsec,$rmin,$rhour,$rmday,$rmon,$ryear); + + ###################################################################################### + # absolute Auswertungszeiträume statische und dynamische (Beginn / Ende) berechnen + ###################################################################################### + $tsbegin = AttrVal($hash->{NAME}, "timestamp_begin", "1970-01-01 01:00:00"); $tsend = AttrVal($hash->{NAME}, "timestamp_end", strftime "%Y-%m-%d %H:%M:%S", localtime(time)); @@ -1368,32 +1399,45 @@ sub createTimeArray($$$) { my ($yyyy1, $mm1, $dd1, $hh1, $min1, $sec1) = ($tsbegin =~ /(\d+)-(\d+)-(\d+) (\d+):(\d+):(\d+)/); # extrahieren der Einzelwerte von Datum/Zeit Ende my ($yyyy2, $mm2, $dd2, $hh2, $min2, $sec2) = ($tsend =~ /(\d+)-(\d+)-(\d+) (\d+):(\d+):(\d+)/); - + + ###################################################################################### + # relative Auswertungszeit Beginn berücksichtigen + ###################################################################################### # Umwandeln in Epochesekunden Beginn my $epoch_seconds_begin = timelocal($sec1, $min1, $hh1, $dd1, $mm1-1, $yyyy1-1900) if($tsbegin); + my ($timeolderthan,$timedifftonow) = normRelativeTime($hash); - if(AttrVal($hash->{NAME}, "timeDiffToNow", undef)) { - $epoch_seconds_begin = time() - AttrVal($hash->{NAME}, "timeDiffToNow", undef); - Log3 ($name, 4, "DbRep $name - Time difference to current time for calculating Timestamp begin: ".AttrVal($hash->{NAME}, "timeDiffToNow", undef)." sec"); - } elsif (AttrVal($hash->{NAME}, "timeOlderThan", undef)) { + if($timedifftonow) { + $epoch_seconds_begin = time() - $timedifftonow; + Log3 ($name, 4, "DbRep $name - Time difference to current time for calculating Timestamp begin: $timedifftonow sec"); + } elsif ($timeolderthan) { $epoch_seconds_begin = timelocal(00, 00, 01, 01, 01-1, 1970-1900); } my $tsbegin_string = strftime "%Y-%m-%d %H:%M:%S", localtime($epoch_seconds_begin); Log3 ($name, 5, "DbRep $name - Timestamp begin epocheseconds: $epoch_seconds_begin") if($opt !~ /tableCurrentPurge/); Log3 ($name, 4, "DbRep $name - Timestamp begin human readable: $tsbegin_string") if($opt !~ /tableCurrentPurge/); - + + ###################################################################################### + # relative Auswertungszeit Ende berücksichtigen + ###################################################################################### # Umwandeln in Epochesekunden Endezeit - my $epoch_seconds_end = timelocal($sec2, $min2, $hh2, $dd2, $mm2-1, $yyyy2-1900); - $epoch_seconds_end = AttrVal($hash->{NAME}, "timeOlderThan", undef) ? (time() - AttrVal($hash->{NAME}, "timeOlderThan", undef)) : $epoch_seconds_end; - Log3 ($name, 4, "DbRep $name - Time difference to current time for calculating Timestamp end: ".AttrVal($hash->{NAME}, "timeOlderThan", undef)." sec") if(AttrVal($hash->{NAME}, "timeOlderThan", undef)); + my $epoch_seconds_end = timelocal($sec2, $min2, $hh2, $dd2, $mm2-1, $yyyy2-1900); + + $epoch_seconds_end = $timeolderthan ? (time() - $timeolderthan) : $epoch_seconds_end; + + #$epoch_seconds_end = AttrVal($hash->{NAME}, "timeOlderThan", undef) ? + # (time() - AttrVal($hash->{NAME}, "timeOlderThan", undef)) : $epoch_seconds_end; + Log3 ($name, 4, "DbRep $name - Time difference to current time for calculating Timestamp end: $timeolderthan sec") if(AttrVal($hash->{NAME}, "timeOlderThan", undef)); my $tsend_string = strftime "%Y-%m-%d %H:%M:%S", localtime($epoch_seconds_end); + Log3 ($name, 5, "DbRep $name - Timestamp end epocheseconds: $epoch_seconds_end") if($opt !~ /tableCurrentPurge/); Log3 ($name, 4, "DbRep $name - Timestamp end human readable: $tsend_string") if($opt !~ /tableCurrentPurge/); - - # Erstellung Wertehash für "collaggstr" + ###################################################################################### + # Erstellung Wertehash für Aggregationen + ###################################################################################### my $runtime = $epoch_seconds_begin; # Schleifenlaufzeit auf Beginn der Zeitselektion setzen my $runtime_string; # Datum/Zeit im SQL-Format für Readingname Teilstring my $runtime_string_first; # Datum/Zeit Auswertungsbeginn im SQL-Format für SQL-Statement @@ -1599,7 +1643,7 @@ sub collaggstr($$$$) { } else { $runtime_string_next = strftime "%Y-%m-%d", localtime($runtime+$aggsec); } - Log3 ($name, 5, "DbRep $name - runtime_string: $runtime_string, runtime_string_first(begin): $runtime_string_first, runtime_string_next(end): $runtime_string_next"); + Log3 ($name, 5, "DbRep $name - runtime_string: $runtime_string, runtime_string_first: $runtime_string_first, runtime_string_next: $runtime_string_next"); # neue Beginnzeit in Epoche-Sekunden $runtime = $runtime+$aggsec; @@ -3369,7 +3413,7 @@ sub currentfillup_Push($) { } else { $sql .= "1 "; } - $sql .= "group by device,reading ;"; + $sql .= "group by timestamp,device,reading ;"; } elsif ($usepkc && $dbloghash->{MODEL} eq 'SQLITE') { $sql = "INSERT OR IGNORE INTO current (TIMESTAMP,DEVICE,READING) SELECT timestamp,device,reading FROM history where "; @@ -3384,10 +3428,10 @@ sub currentfillup_Push($) { } else { $sql .= "1 "; } - $sql .= "group by device,reading ;"; + $sql .= "group by timestamp,device,reading ;"; } elsif ($usepkc && $dbloghash->{MODEL} eq 'POSTGRESQL') { - $sql = "INSERT INTO current (TIMESTAMP,DEVICE,READING) SELECT '2017-01-01 00:00:00',device,reading FROM history where "; + $sql = "INSERT INTO current (TIMESTAMP,DEVICE,READING) SELECT '$runtime_string_next',device,reading FROM history where "; $sql .= "DEVICE LIKE '$devs' AND " if($danz <= 1 && $devs !~ m(^%$) && $devs =~ m(\%)); $sql .= "DEVICE = '$devs' AND " if($danz <= 1 && $devs !~ m(\%)); $sql .= "DEVICE IN ($devs) AND " if($danz > 1); @@ -3419,7 +3463,7 @@ sub currentfillup_Push($) { $sql .= "group by device,reading ;"; } else { # PostgreSQL - $sql = "INSERT INTO current (TIMESTAMP,DEVICE,READING) SELECT '2017-01-01 00:00:00',device,reading FROM history where "; + $sql = "INSERT INTO current (TIMESTAMP,DEVICE,READING) SELECT '$runtime_string_next',device,reading FROM history where "; $sql .= "DEVICE LIKE '$devs' AND " if($danz <= 1 && $devs !~ m(^%$) && $devs =~ m(\%)); $sql .= "DEVICE = '$devs' AND " if($danz <= 1 && $devs !~ m(\%)); $sql .= "DEVICE IN ($devs) AND " if($danz > 1); @@ -3465,7 +3509,7 @@ sub currentfillup_Push($) { $irow = $sth->rows; $dbh->disconnect(); } - + # SQL-Laufzeit ermitteln my $rt = tv_interval($st); @@ -3691,6 +3735,8 @@ sub fetchrows_DoParse($) { my $dbpassword = $attr{"sec$dblogname"}{secret}; my $limit = AttrVal($name, "limit", 1000); my $utf8 = defined($hash->{UTF8})?$hash->{UTF8}:0; + my $fetchroute = AttrVal($name, "fetchRoute", "descent"); + $fetchroute = ($fetchroute eq "descent")?"DESC":"ASC"; my ($err,$dbh,$sth,$sql,$rowlist,$nrows); # Background-Startzeit @@ -3711,9 +3757,9 @@ sub fetchrows_DoParse($) { # SQL zusammenstellen für DB-Abfrage if ($IsTimeSet) { - $sql = createSelectSql($hash,$table,"DEVICE,READING,TIMESTAMP,VALUE,UNIT",$device,$reading,"'$runtime_string_first'","'$runtime_string_next'","ORDER BY TIMESTAMP DESC LIMIT ".($limit+1)); + $sql = createSelectSql($hash,$table,"DEVICE,READING,TIMESTAMP,VALUE,UNIT",$device,$reading,"'$runtime_string_first'","'$runtime_string_next'","ORDER BY TIMESTAMP $fetchroute LIMIT ".($limit+1)); } else { - $sql = createSelectSql($hash,$table,"DEVICE,READING,TIMESTAMP,VALUE,UNIT",$device,$reading,undef,undef,"ORDER BY TIMESTAMP DESC LIMIT ".($limit+1)); + $sql = createSelectSql($hash,$table,"DEVICE,READING,TIMESTAMP,VALUE,UNIT",$device,$reading,undef,undef,"ORDER BY TIMESTAMP $fetchroute LIMIT ".($limit+1)); } $sth = $dbh->prepare($sql); @@ -3732,7 +3778,7 @@ sub fetchrows_DoParse($) { return "$name|''|''|$err|''"; } - no warnings 'uninitialized'; + no warnings 'uninitialized'; my @row_array = map { $_ -> [0]." ".$_ -> [1]." ".$_ -> [2]." ".$_ -> [3]." ".$_ -> [4]."\n" } @{$sth->fetchall_arrayref()}; use warnings; $nrows = $#row_array+1; # Anzahl der Ergebniselemente @@ -3800,22 +3846,22 @@ sub fetchrows_ParseDone($) { readingsBeginUpdate($hash); foreach my $row (@row_array) { - my @a = split("[ \t][ \t]*", $row, 5); - my $dev = $a[0]; - my $rea = $a[1]; - $a[3] =~ s/:/-/g; # substituieren unsopported characters ":" -> siehe fhem.pl - my $ts = $a[2]."_".$a[3]; - my $val = $a[4]; - my $unt = $a[5]; + my @a = split("[ \t][ \t]*", $row, 5); + my $dev = $a[0]; + my $rea = $a[1]; + $a[3] =~ s/:/-/g; # substituieren unsupported characters ":" -> siehe fhem.pl + my $ts = $a[2]."_".$a[3]; + my $val = $a[4]; + my $unt = $a[5]; - if ($reading && AttrVal($hash->{NAME}, "readingNameMap", "")) { - $reading_runtime_string = $ts."__".AttrVal($hash->{NAME}, "readingNameMap", "") ; - } else { - $reading_runtime_string = $ts."__".$dev."__".$rea; - } + if ($reading && AttrVal($hash->{NAME}, "readingNameMap", "")) { + $reading_runtime_string = $ts."__".AttrVal($hash->{NAME}, "readingNameMap", "") ; + } else { + $reading_runtime_string = $ts."__".$dev."__".$rea; + } - $val = $unt?$val." ".$unt:$val; - ReadingsBulkUpdateValue($hash, $reading_runtime_string, $val); + $val = $unt?$val." ".$unt:$val; + ReadingsBulkUpdateValue($hash, $reading_runtime_string, $val); } my $sfx = AttrVal("global", "language", "EN"); $sfx = ($sfx eq "EN" ? "" : "_$sfx"); @@ -3831,6 +3877,256 @@ sub fetchrows_ParseDone($) { return; } +#################################################################################################### +# DB-Abfrage delSeqDoublets +#################################################################################################### +sub delseqdoubl_DoParse($) { + my ($string) = @_; + my ($name,$opt,$device,$reading,$ts) = split("\\§", $string); + my $hash = $defs{$name}; + my $dbloghash = $hash->{dbloghash}; + my $dbconn = $dbloghash->{dbconn}; + my $dbuser = $dbloghash->{dbuser}; + my $dblogname = $dbloghash->{NAME}; + my $dbpassword = $attr{"sec$dblogname"}{secret}; + my $utf8 = defined($hash->{UTF8})?$hash->{UTF8}:0; + my $table = "history"; + my ($err,$dbh,$sth,$sql,$rowlist,$nrows,$selspec,$st); + + # Background-Startzeit + my $bst = [gettimeofday]; + + Log3 ($name, 4, "DbRep $name -> Start BlockingCall delseqdoubl_DoParse"); + + eval {$dbh = DBI->connect("dbi:$dbconn", $dbuser, $dbpassword, { PrintError => 0, RaiseError => 1, AutoInactiveDestroy => 1, mysql_enable_utf8 => $utf8 });}; + if ($@) { + $err = encode_base64($@,""); + Log3 ($name, 2, "DbRep $name - $@"); + Log3 ($name, 4, "DbRep $name -> BlockingCall delseqdoubl_DoParse finished"); + return "$name|''|''|$err|''|$opt"; + } + + # Timestampstring to Array + my @ts = split("\\|", $ts); + Log3 ($name, 5, "DbRep $name - Timestamp-Array: \n@ts"); + + + # ist Zeiteingrenzung und/oder Aggregation gesetzt ? (wenn ja -> "'$runtime_string_*'"|"?" in SQL sonst undef) + my ($IsTimeSet,$IsAggrSet) = checktimeaggr($hash); + + $selspec = "DEVICE,READING,TIMESTAMP,VALUE"; + + # SQL zusammenstellen für DB-Abfrage + if ($IsTimeSet || $IsAggrSet) { + $sql = createSelectSql($hash,$table,$selspec,$device,$reading,"?","?","ORDER BY TIMESTAMP ASC"); + } else { + $sql = createSelectSql($hash,$table,$selspec,$device,$reading,undef,undef,"ORDER BY TIMESTAMP ASC"); + } + + $sth = $dbh->prepare($sql); + + # DB-Abfrage zeilenweise für jeden Timearray-Eintrag + my @row_array; + my @remain; + my @todel; + my $ndel = 0; + my $rt = 0; + + no warnings 'uninitialized'; + + foreach my $row (@ts) { + my @a = split("#", $row); + my $runtime_string = $a[0]; + my $runtime_string_first = $a[1]; + my $runtime_string_next = $a[2]; + $runtime_string = encode_base64($runtime_string,""); + + # SQL-Startzeit + $st = [gettimeofday]; + + # SQL zusammenstellen für Logausgabe + if ($IsTimeSet || $IsAggrSet) { + $sql = createSelectSql($hash,"history",$selspec,$device,$reading,"'$runtime_string_first'","'$runtime_string_next'",''); + } + Log3 ($name, 4, "DbRep $name - SQL execute: $sql"); + + if ($IsTimeSet || $IsAggrSet) { + eval{$sth->execute($runtime_string_first, $runtime_string_next);}; + } else { + eval{$sth->execute();}; + } + if ($@) { + $err = encode_base64($@,""); + Log3 ($name, 2, "DbRep $name - $@"); + $dbh->disconnect; + Log3 ($name, 4, "DbRep $name -> BlockingCall delseqdoubl_DoParse finished"); + return "$name|''|''|$err|''|$opt"; + } + + # SQL-Laufzeit ermitteln + $rt = $rt+tv_interval($st); + + @row_array = map { $_->[0]."_ESC_".$_->[1]."_ESC_".$_->[2]."_ESC_".$_->[3]."\n" } @{$sth->fetchall_arrayref()}; + + $nrows = $#row_array+1; # Anzahl der Ergebniselemente + s/ /_ESC_/ for @row_array; # Leerzeichen in TIMESTAMP escapen + + # Beginn Löschlogik, Zusammenstellen der löschenden DS (warping) + # Die Arrays @remain, @sel enthalten die VERBLEIBENDEN Datensätze + my $i = 0; + my (@sel,@warp); + my ($or,$oor,$odev,$oread,$oval,$ooval,$ndev,$nread,$nval); + + my @sort = sort @row_array; # Reihenfolge device,reading sortieren + foreach my $nr (@sort) { + if($i == 0 || $i == $#sort) { + push (@sel,$nr); + } else { + ($ndev,$nread,undef,undef,$nval) = split("_ESC_", $nr); # Werte des aktuellen Elements + $or = pop @sel; # das letzte Element der Liste + ($odev,$oread,undef,undef,$oval) = split("_ESC_", $or); # Value des letzten Elements + $oor = pop @sel; # das vorletzte Element der Liste + $ooval = (split '_ESC_', $oor)[-1]; # Value des vorletzten Elements + if ($ndev.$nread ne $odev.$oread) { + push (@sel,$oor); + push (@sel,$or); + push (@sel,$nr); + } elsif ($ooval eq $oval) { + push (@sel,$oor); + push (@sel,$nr); + # Log3 ($name, 5, "DbRep $name -> warping: $or"); + push (@warp,$or); # Array der zu löschenden Datensätze + if ($opt =~ /delete/ && $or) { # delete Datensätze + my ($dev,$read,$date,$time,$val) = split("_ESC_", $or); + my $dt = $date." ".$time; + $val =~ tr/"\n"//d; + $st = [gettimeofday]; + my $dsql = "delete FROM $table where TIMESTAMP = '$dt' AND DEVICE = '$dev' AND READING = '$read' AND VALUE ='$val';"; + $sth = $dbh->prepare($dsql); + Log3 ($name, 4, "DbRep $name - SQL execute: $dsql"); + + eval {$sth->execute();}; + if ($@) { + $err = encode_base64($@,""); + Log3 ($name, 2, "DbRep $name - $@"); + $dbh->disconnect; + Log3 ($name, 4, "DbRep $name -> BlockingCall delseqdoubl_DoParse finished"); + return "$name|''|''|$err|''|$opt"; + } + $ndel = $ndel+$sth->rows; + $dbh->commit() if(!$dbh->{AutoCommit}); + + $rt = $rt+tv_interval($st); + } + } else { + push (@sel,$oor); + push (@sel,$or); + push (@sel,$nr); + } + } + $i++; + } + + push(@remain,@sel) if(@sel); # die verbleibenden Datensätze nach Ausführung + push(@todel,@warp) if(@warp); # die zu löschenden Datensätze + # Ende Löschlogik + } + + my $nremain = $#remain+1; + my $ntodel = $#todel+1; + my $retn = ($opt =~ /adviceRemain/)?$nremain:($opt =~ /adviceDelete/)?$ntodel:$ndel; + + my @retarray = ($opt =~ /adviceRemain/)?@remain:($opt =~ /adviceDelete/)?@todel:" "; + if ($utf8 && @retarray) { + $rowlist = Encode::encode_utf8(join('|', @retarray)); + } elsif(@retarray) { + $rowlist = join('|', @retarray); + } else { + $rowlist = 0; + } + + use warnings; + Log3 ($name, 5, "DbRep $name -> row result list:\n$rowlist"); + + $dbh->disconnect; + + # Daten müssen als Einzeiler zurückgegeben werden + $rowlist = encode_base64($rowlist,""); + + Log3 ($name, 4, "DbRep $name -> BlockingCall delseqdoubl_DoParse finished"); + + # Background-Laufzeit ermitteln + my $brt = tv_interval($bst); + + $rt = $rt.",".$brt; + +return "$name|$rowlist|$rt|0|$retn|$opt"; +} + +#################################################################################################### +# Auswertungsroutine delSeqDoublets +#################################################################################################### +sub delseqdoubl_ParseDone($) { + my ($string) = @_; + my @a = split("\\|",$string); + my $hash = $defs{$a[0]}; + my $rowlist = decode_base64($a[1]); + my $bt = $a[2]; + my ($rt,$brt) = split(",", $bt); + my $err = $a[3]?decode_base64($a[3]):undef; + my $nrows = $a[4]; + my $opt = $a[5]; + my $name = $hash->{NAME}; + my $reading = AttrVal($name, "reading", undef); + my @row; + my $reading_runtime_string; + + Log3 ($name, 4, "DbRep $name -> Start BlockingCall delseqdoubl_ParseDone"); + + if ($err) { + ReadingsSingleUpdateValue ($hash, "errortext", $err, 1); + ReadingsSingleUpdateValue ($hash, "state", "error", 1); + delete($hash->{HELPER}{RUNNING_PID}); + Log3 ($name, 4, "DbRep $name -> BlockingCall delseqdoubl_ParseDone finished"); + return; + } + + # Readingaufbereitung + readingsBeginUpdate($hash); + + no warnings 'uninitialized'; + if ($opt !~ /delete/ && $rowlist) { + my @row_array = split("\\|", $rowlist); + Log3 ($name, 5, "DbRep $name - row_array decoded: @row_array"); + foreach my $row (@row_array) { + $row =~ s/_ESC_/ /g; + my @a = split("[ \t][ \t]*", $row, 5); + my $dev = $a[0]; + my $rea = $a[1]; + $a[3] =~ s/:/-/g; # substituieren unsupported characters ":" -> siehe fhem.pl + my $ts = $a[2]."_".$a[3]; + my $val = $a[4]; + + if ($reading && AttrVal($hash->{NAME}, "readingNameMap", "")) { + $reading_runtime_string = $ts."__".AttrVal($hash->{NAME}, "readingNameMap", "") ; + } else { + $reading_runtime_string = $ts."__".$dev."__".$rea; + } + ReadingsBulkUpdateValue($hash, $reading_runtime_string, $val); + } + } + use warnings; + + my $rnam = ($opt =~ /adviceRemain/)?"number_rows_to_remain":($opt =~ /adviceDelete/)?"number_rows_to_delete":"number_rows_deleted"; + ReadingsBulkUpdateValue($hash, "$rnam", "$nrows"); + ReadingsBulkUpdateTimeState($hash,$brt,$rt,"done"); + readingsEndUpdate($hash, 1); + + delete($hash->{HELPER}{RUNNING_PID}); + Log3 ($name, 4, "DbRep $name -> BlockingCall delseqdoubl_ParseDone finished"); +return; +} + #################################################################################################### # nichtblockierende DB-Funktion expfile #################################################################################################### @@ -5349,10 +5645,13 @@ sub mysql_DoDumpClientSide($) { $rt = $rt.",".$brt; + my $fsize = byte_output($filesize); + $fsize = encode_base64($fsize,""); + Log3 ($name, 3, "DbRep $name - Finished backup of database $dbname, total time used: ".sprintf("%.0f",$brt)." sec."); Log3 ($name, 4, "DbRep $name -> BlockingCall mysql_DoDumpClientSide finished"); -return "$name|$rt|''|$sql_file|$drc|$drh|$filesize|$ftp|$bfd"; +return "$name|$rt|''|$sql_file|$drc|$drh|$fsize|$ftp|$bfd"; } #################################################################################################### @@ -5504,13 +5803,16 @@ sub mysql_DoDumpServerSide($) { # Background-Laufzeit ermitteln my $brt = tv_interval($bst); + + my $fsize = byte_output($filesize); + $fsize = encode_base64($fsize,""); $rt = $rt.",".$brt; Log3 ($name, 3, "DbRep $name - Finished backup of database $dbname - total time used: ".sprintf("%.0f",$brt)." seconds"); Log3 ($name, 4, "DbRep $name -> BlockingCall mysql_DoDumpServerSide finished"); -return "$name|$rt|''|$dump_path_rem$bfile|n.a.|$drh|$filesize|$ftp|$bfd"; +return "$name|$rt|''|$dump_path_rem$bfile|n.a.|$drh|$fsize|$ftp|$bfd"; } #################################################################################################### @@ -5526,7 +5828,7 @@ sub DumpDone($) { my $bfile = $a[3]; my $drc = $a[4]; my $drh = $a[5]; - my $fs = $a[6]; + my $fs = $a[6]?decode_base64($a[6]):undef; my $ftp = $a[7]?decode_base64($a[7]):undef; my $bfd = $a[8]?decode_base64($a[8]):undef; my $name = $hash->{NAME}; @@ -5947,6 +6249,80 @@ sub ReadingsBulkUpdateTimeState ($$$$) { return; } +#################################################################################################### +# relative Zeitangaben als Sekunden normieren +# +# liefert die Attribute timeOlderThan, timeDiffToNow als Sekunden normiert zurück +#################################################################################################### +sub normRelativeTime ($) { + my ($hash) = @_; + my $name = $hash->{NAME}; + + my $tdtn = AttrVal($name, "timeDiffToNow", undef); + my $toth = AttrVal($name, "timeOlderThan", undef); + + if($tdtn && $tdtn =~ /^\s*[dhms]:(([\d]+.[\d]+)|[\d]+)\s*/) { + my ($d,$h,$m,$s); + if($tdtn =~ /.*d:(([\d]+.[\d]+)|[\d]+).*/) { + $d = $tdtn; + $d =~ s/.*d:(([\d]+.[\d]+)|[\d]+).*/$1/e; + } + if($tdtn =~ /.*h:(([\d]+.[\d]+)|[\d]+).*/) { + $h = $tdtn; + $h =~ s/.*h:(([\d]+.[\d]+)|[\d]+).*/$1/e; + } + if($tdtn =~ /.*m:(([\d]+.[\d]+)|[\d]+).*/) { + $m = $tdtn; + $m =~ s/.*m:(([\d]+.[\d]+)|[\d]+).*/$1/e; + } + if($tdtn =~ /.*s:(([\d]+.[\d]+)|[\d]+).*/) { + $s = $tdtn; + $s =~ s/.*s:(([\d]+.[\d]+)|[\d]+).*/$1/e ; + } + + no warnings 'uninitialized'; + Log3($name, 4, "DbRep $name - timeDiffToNow - day: $d, hour: $h, min: $m, sec: $s "); + use warnings; + $d = $d?($d*86400):0; + $h = $h?($h*3600):0; + $m = $m?($m*60):0; + $s = $s?$s:0; + + $tdtn = $d + $h + $m +$s; + } + + if($toth && $toth =~ /^\s*[dhms]:(([\d]+.[\d]+)|[\d]+)\s*/) { + my ($d,$h,$m,$s); + if($toth =~ /.*d:(([\d]+.[\d]+)|[\d]+).*/) { + $d = $toth; + $d =~ s/.*d:(([\d]+.[\d]+)|[\d]+).*/$1/e; + } + if($toth =~ /.*h:(([\d]+.[\d]+)|[\d]+).*/) { + $h = $toth; + $h =~ s/.*h:(([\d]+.[\d]+)|[\d]+).*/$1/e; + } + if($toth =~ /.*m:(([\d]+.[\d]+)|[\d]+).*/) { + $m = $toth; + $m =~ s/.*m:(([\d]+.[\d]+)|[\d]+).*/$1/e; + } + if($toth =~ /.*s:(([\d]+.[\d]+)|[\d]+).*/) { + $s = $toth; + $s =~ s/.*s:(([\d]+.[\d]+)|[\d]+).*/$1/e ; + } + + no warnings 'uninitialized'; + Log3($name, 4, "DbRep $name - timeDiffToNow - day: $d, hour: $h, min: $m, sec: $s "); + use warnings; + $d = $d?($d*86400):0; + $h = $h?($h*3600):0; + $m = $m?($m*60):0; + $s = $s?$s:0; + + $toth = $d + $h + $m +$s; + } +return ($toth,$tdtn); +} + #################################################################################################### # userexit - Funktion um userspezifische Programmaufrufe nach Aktualisierung eines Readings # zu ermöglichen, arbeitet OHNE Event abhängig vom Attr userExitFn @@ -6453,6 +6829,7 @@ return;
  • report of existing database processes (MySQL)
  • purge content of current-table
  • fill up the current-table with a (tunable) extract of the history-table
    • +
  • delete consecutive datasets (clearing up consecutive doublets)

    • @@ -6534,11 +6911,73 @@ return; "timestamp_end" is set : deletes db entries until this timestamp
    both Timestamps are set : deletes db entries between these timestamps

    - Due to security reasons the attribute "allowDeletion" needs to be set to unlock the delete-function.
    + Due to security reasons the attribute attribute "allowDeletion" needs to be set to unlock the + delete-function.

    +
  • delSeqDoublets [adviceRemain | adviceDelete | delete] - show respectively delete identical sequentially datasets. + Therefore Device,Reading and Value of the sequentially datasets are compared. + Not deleted are the first und the last dataset of a aggregation period (e.g. hour,day,week and so on) as + well as the datasets before or after a value change (database field VALUE).
    + The attributes to define the scope of aggregation,time period, device and reading are + considered. If attribute aggregation is not set or set to "no", it will change to the default aggregation + period "day". +

    + + +
    + + Due to security reasons the attribute attribute "allowDeletion" needs to be set for + execute the "delete" option.

    + + + + +
    • +
    +
    +
  • deviceRename - renames the device name of a device inside the connected database (Internal DATABASE). The devicename will allways be changed in the entire database. Possibly set time limits or restrictions by attributes device and/or reading will not be considered.

    @@ -6598,7 +7037,7 @@ return; optimization want to be used !

    After the dump a FHEM-command can be executed as well (see attribute "executeAfterDump").
    - By other attributes the run-time behavior of the function can be + By the attributes "dumpMemlimit" and "dumpSpeed" the run-time behavior of the function can be controlled to optimize the performance and demand of ressources.

    The attributes relevant for function "dumpMySQL clientSide" are "dumpComment", "dumpDirLocal", "dumpMemlimit", @@ -6707,7 +7146,10 @@ return;
  • fetchrows [history|current] - provides all table-entries (default: history) between period given by timestamp-attributes. - A possibly set aggregation will not be considered.

    • + A possibly aggregation set will not be considered.
    + The direction of data selection can be determined by attribute + "fetchRoute".
    +
  • insert - use it to insert data ito table "history" manually. Input values for Date, Time and Value are mandatory. The database fields for Type and Event will be filled in with "manual" automatically and the values of Device, Reading will be get from set attributes.

    @@ -7090,6 +7532,18 @@ sub bdump {
  • expimpfile - Path/filename for data export/import

    • +
  • fetchRoute [descent | ascent] - specify the direction of data selection of the fetchrows-command.

    + + +


    • +
  • ftpUse - FTP Transfer after dump will be switched on (without SSL encoding). The created database backup file will be transfered non-blocking to the FTP-Server (Attribut "ftpServer").

    • @@ -7275,17 +7729,29 @@ sub bdump { The setting of "timestamp_begin" respectively "timestamp_end" causes the deletion of attribute "timeDiffToNow" if it was set before as well.

    -
  • timeDiffToNow - the begin of data selection will be set to the timestamp "<current time> - - <timeDiffToNow>" dynamically (in seconds). Thereby always the last - <timeDiffToNow>-seconds will be considered (e.g. if set to 86400, always the last - 24 hours should assumed). The Timestamp calculation will be done dynamically at execution - time.

    • +
  • timeDiffToNow - the begin of data selection will be set to the timestamp "<current time> - + <timeDiffToNow>" dynamically (e.g. if set to 86400, the last 24 hours are considered by data + selection). The time period will be calculated dynamically at execution time.

    • -
  • timeOlderThan - the end of data selection will be set to the timestamp "<aktuelle Zeit> - - <timeOlderThan>" dynamically (in seconds). Always the datasets up to timestamp + +

    + +
  • timeOlderThan - the end of data selection will be set to the timestamp "<aktuelle Zeit> - + <timeOlderThan>" dynamically. Always the datasets up to timestamp "<current time> - <timeOlderThan>" will be considered (e.g. if set to - 86400, all datasets older than one day will be considered). The Timestamp calculation - will be done dynamically at execution time.

    • + 86400, all datasets older than one day are considered). The time period will be calculated dynamically at + execution time.
    + The valid input format for attribute "timeOlderThan" is identical to attribute "timeDiffToNow".
  • timeout - set the timeout-value for Blocking-Call Routines in background in seconds (default 86400)

    • @@ -7465,7 +7931,7 @@ sub bdump {
  • Ausgabe der existierenden Datenbankprozesse (MySQL)
  • leeren der current-Tabelle
  • Auffüllen der current-Tabelle mit einem (einstellbaren) Extrakt der history-Tabelle
    • - +
  • Bereinigung sequentiell aufeinander folgender Datensätze (sequentielle Dublettenbereinigung)

    • @@ -7536,7 +8002,7 @@ sub bdump {
  • cancelDump - bricht einen laufenden Datenbankdump ab.

    • -
  • countEntries [history|current] - liefert die Anzahl der Tabelleneinträge (default: history) in den gegebenen +
  • countEntries [history | current] - liefert die Anzahl der Tabelleneinträge (default: history) in den gegebenen Zeitgrenzen (siehe Attribute). Sind die Timestamps nicht gesetzt werden alle Einträge gezählt. Beschränkungen durch die Attribute Device bzw. Reading @@ -7558,6 +8024,69 @@ sub bdump {
    +
  • delSeqDoublets [adviceRemain | adviceDelete | delete] - zeigt bzw. löscht aufeinander folgende identische Datensätze. + Dazu wird Device,Reading und Value ausgewertet. Nicht gelöscht werden der erste und der letzte Datensatz + einer Aggregationsperiode (z.B. hour, day, week usw.) sowie die Datensätze vor oder nach einem Wertewechsel + (Datenbankfeld VALUE).
    + Die Attribute zur Aggregation,Zeit-,Device- und Reading-Abgrenzung werden dabei + berücksichtigt. Ist das Attribut "aggregation" nicht oder auf "no" gesetzt, wird als Standard die Aggregation + "day" verwendet. +

    + + +
    + + Aus Sicherheitsgründen muss das Attribut "allowDeletion" für die "delete" Option + gesetzt sein.

    + + + + +
    • +
    +
    + +
  • deviceRename - benennt den Namen eines Device innerhalb der angeschlossenen Datenbank (Internal DATABASE) um. Der Gerätename wird immer in der gesamten Datenbank umgesetzt. Eventuell gesetzte @@ -7618,8 +8147,8 @@ sub bdump { Tabellenoptimierung verwendet wird !

    Nach dem Dump kann ebenfalls ein FHEM-Kommando (siehe "executeAfterDump") ausgeführt werden.
    - Über weitere Attribute kann das Laufzeitverhalten der Funktion beeinflusst - werden um eine Optimierung bezüglich Performance und Ressourcenbedarf zu erreichen.
    + Über die Attribute "dumpMemlimit" und "dumpSpeed" kann das Laufzeitverhalten der + Funktion beeinflusst werden um eine Optimierung bezüglich Performance und Ressourcenbedarf zu erreichen.
    Die für "dumpMySQL clientSide" relevanten Attribute sind "dumpComment", "dumpDirLocal", "dumpMemlimit", "dumpSpeed ", "dumpFilesKeep", "executeBeforeDump", "executeAfterDump" und "optimizeTablesBeforeDump".
    @@ -7724,7 +8253,9 @@ sub bdump {
  • fetchrows [history|current] - liefert alle Tabelleneinträge (default: history) in den gegebenen Zeitgrenzen (siehe Attribute). - Eine evtl. gesetzte Aggregation wird nicht berücksichtigt.

    + Eine evtl. gesetzte Aggregation wird nicht berücksichtigt.
    + Die Leserichtung in der Datenbank kann durch das Attribut + "fetchRoute" bestimmt werden.

    Hinweis:
    Auch wenn das Modul bezüglich der Datenbankabfrage nichtblockierend arbeitet, kann eine @@ -8123,6 +8654,18 @@ sub bdump {
  • expimpfile - Pfad/Dateiname für Export/Import in/aus einem File.

    • +
  • fetchRoute [descent | ascent] - bestimmt die Leserichtung des fetchrows-Befehl.

    + + +


    • +
  • ftpUse - FTP Transfer nach dem Dump wird eingeschaltet (ohne SSL Verschlüsselung). Das erzeugte Datenbank Backupfile wird non-blocking zum angegebenen FTP-Server (Attribut "ftpServer") übertragen.

    • @@ -8309,16 +8852,29 @@ sub bdump { Das Setzen von "timestamp_begin" bzw. "timestamp_end" bedingt die Löschung von Attribut "timeDiffToNow" wenn es vorher gesetzt war.

    -
  • timeDiffToNow - der Selektionsbeginn wird auf den Zeitpunkt "<aktuelle Zeit> - <timeDiffToNow>" - gesetzt (in Sekunden). Es werden immer die letzten <timeDiffToNow>-Sekunden - berücksichtigt (z.b. 86400 wenn immer die letzten 24 Stunden in die Selektion eingehen - sollen). Die Timestampermittlung erfolgt dynamisch zum Ausführungszeitpunkt.

    • +
  • timeDiffToNow - der Selektionsbeginn wird auf den Zeitpunkt "<aktuelle Zeit> - <timeDiffToNow>" + gesetzt (z.b. werden die letzten 24 Stunden in die Selektion eingehen wenn das Attribut auf "86400" gesetzt + wurde). Die Timestampermittlung erfolgt dynamisch zum Ausführungszeitpunkt.

    • -
  • timeOlderThan - das Selektionsende wird auf den Zeitpunkt "<aktuelle Zeit> - <timeOlderThan>" - gesetzt (in Sekunden). Dadurch werden alle Datensätze bis zu dem Zeitpunkt "<aktuelle - Zeit> - <timeOlderThan>" berücksichtigt (z.b. wenn auf 86400 gesetzt werden alle + +

    + +
  • timeOlderThan - das Selektionsende wird auf den Zeitpunkt "<aktuelle Zeit> - <timeOlderThan>" + gesetzt. Dadurch werden alle Datensätze bis zu dem Zeitpunkt "<aktuelle + Zeit> - <timeOlderThan>" berücksichtigt (z.b. wenn auf 86400 gesetzt, werden alle Datensätze die älter als ein Tag sind berücksichtigt). Die Timestampermittlung erfolgt - dynamisch zum Ausführungszeitpunkt.

    • + dynamisch zum Ausführungszeitpunkt.
    + Es gelten die gleichen Eingabeformate wie für das Attribut "timeDiffToNow".
  • timeout - das Attribut setzt den Timeout-Wert für die Blocking-Call Routinen in Sekunden (Default: 86400)