Page History

#PARSER PQL
#RUNQUERY
timer = TIMER({
            period = -1,
            timefromstart = true,
            source = 'controllerTimer'
          }
        )

enrich = MAP({
              expressions = [
                ['kvReadString("query_store",toString(0))','query'],
                ['kvWrite("context_store","currentQuery","Query0")','ignore']
              ]
            },
            timer
          )

command = COMMAND({
              commandexpression='addQuery(query,"OdysseusScript")'
            },
            enrich
          )

#RUNQUERY
input = ACCESS({
            transport='RabbitMQ',
            source= 'Receiver',
            wrapper='GenericPush',
            protocol='csv',
            datahandler='Tuple',
            options=[
              ['QUEUE_NAME','Ody_Monitor'],
              ['CONSUMER_TAG','example'],
              ['HOST','localhost'],
              ['ByteOrder', 'LittleEndian']
            ],
            schema=[['time', 'StartTimestamp']]                                                  
          }                        
        )
        
filter = SELECT({
              predicate = 'time > 10000'
            },
            input
          )

command = COMMAND({
              commandexpression='removeQueryByName(kvReadString("context_store","currentQuery"))'
            },
            filter
          )        

enrich = MAP({
              expressions = [
                ['kvReadString("query_store",toString(1))','query'],
                ['kvWrite("context_store","currentQuery","Query1")','ignore']
              ]
            },
            command
          )

command2 = COMMAND({
              commandexpression='addQuery(query,"OdysseusScript")'
            },
            enrich
          )