Status and elapsed time of logstash batch

Hi All,

Can any one tell me how to get status and elapsed time of my logstash batch(pipe/job). I have below config file.

Hi all,

Please help me out to find the time elapsed and status of the logstash job(logstash pipe) into the mongodb collection. My code as below,

my code is as below,

input {
    jdbc {
        jdbc_connection_string => "jdbc:oracle:thin:@01hw791865.India.TCS.com:1521/XE"
        jdbc_user => "SYSTEM"
        jdbc_password => "Vijaya"
        jdbc_driver_library => "C:\Users\915360.m2\repository\oracle\ojdbc6\11.2.0.3\ojdbc6-11.2.0.3.jar"
        jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
        statement => “SELECT to_char(sysdate,‘YYYYMMDDHH’) as batchid, CUSTOMER.CUSTOMERID,CUSTOMER.FIRSTNAME,CUSTOMER.LASTNAME,CUSTOMER.DOB,’ [ ‘||LISTAGG(’{ ‘||chr(34)||‘agentid’||chr(34)||’ : ‘||nvl(AGENTDETAILS.AGENTID,-1)||’, ‘||chr(34)||‘agentfn’||chr(34)||’ : ‘||chr(34)||nvl(AGENTDETAILS.FIRSTNAME,’-1’)||chr(34)||’, ‘||chr(34)||‘agentln’||chr(34)||’ : ‘||chr(34)||nvl(AGENTDETAILS.LASTNAME,’-1’)||chr(34)||’, ‘||chr(34)||‘agencyname’||chr(34)||’ : ‘||chr(34)||nvl(AGENTDETAILS.AGENCYNAME,’-1’)||chr(34)||’}’ ,’,’) within group (order by agentdetails.agentid) || ’ ] ’ as agents_unparsed,replace(’ [ ‘||RTRIM(REGEXP_REPLACE(LISTAGG(’{ ‘||chr(34)||‘policyno’||chr(34)||’ : ‘||chr(34)||policydetails.policyno||chr(34)||’, ‘||chr(34)||‘policytype’||chr(34)||’ : ‘||chr(34)||policydetails.policytype||chr(34)||’ }’ ,’;’) within group (order by policydetails.policyno),’([^;]*)(;\1)+($|;)’,’\1\3’),’;’) || ’ ] ‘,’;’,’,’) as policy_unparsed FROM MV_PROMPT_LTAM.CUSTOMER LEFT OUTER JOIN MV_PROMPT_LTAM.CUSTOMERAGENT ON CUSTOMERAGENT.CUSTOMERID = CUSTOMER.CUSTOMERID LEFT OUTER JOIN MV_PROMPT_LTAM.AGENTDETAILS ON CUSTOMERAGENT.AGENTID = AGENTDETAILS.AGENTID LEFT OUTER JOIN MV_PROMPT_LTAM.CUSTOMERPOLICY ON CUSTOMER.CUSTOMERID = CUSTOMERPOLICY.CUSTOMERID LEFT OUTER JOIN MV_PROMPT_LTAM.POLICYDETAILS ON CUSTOMERPOLICY.POLICYNO = POLICYDETAILS.POLICYNO GROUP BY CUSTOMER.CUSTOMERID,CUSTOMER.FIRSTNAME,CUSTOMER.LASTNAME,CUSTOMER.DOB”
    }
}
filter {
    json {
         source => "agents_unparsed"
         target => “agents”
    }
    json {
         source => "policy_unparsed"
         target => “policy”
    }
    mutate{
         remove_field => [“agents_unparsed”,“policy_unparsed”]
    }

    elapsed {
         start_tag => “taskstarted”
         end_tag => “taskended”
         unique_id_field => “batchid”
         timeout => 10000
         new_event_on_match => true
    }
output {
    mongodb {
         uri => "mongodb://localhost:27017/"
         database => "customer"
         collection => "customer_nested"
         isodate => true
    }
}

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.