Skip to main content

Trace Inject Trigers

Connectors for IgniteConnex Monitoring

IgniteConnex Monitoring offers a set of versatile connectors that enhance your monitoring capabilities and facilitate seamless communication with the monitoring system. These connectors enable you to push various types of information to IgniteConnex for efficient tracking and management of your runtime applications. Below are the connectors available:

1) Trace Inject Triggers

The Trace Inject Triggers Connector allows you to push inject node triggers to IgniteConnex Monitoring. This feature enables you to closely monitor and track the execution of workflow runs triggered by inject nodes, providing valuable insights into your runtime application's behavior.


Sample msg.data:

msg.data =
{
"comment": "Sync Employees with Salesforce",
"tag": "Daily Sync"
}

msg.topic = 'Example Topic'


2) Get Inject Triggers

Using this connector we can get how many inject nodes are triggered in what time from igniteconnex monitoring system.


Note: You need to save "IGNITE_API_SECRET" in the environments of a runtime.

Sample flow json:

[{"id":"4a06807022b84322","type":"subflow","name":"Get Inject Triggers","info":"# About Get Inject Triggers:\r\nUsing this connector we can get how many inject nodes are triggered in what time from igniteconnex monitoring system.\r\n\r\n`\r\nNote: You need to save **\"IGNITE_API_SECRET\"** in environments of a runtime.\r\n`\r\n\r\n## Overriding Connector Properties:\r\n\r\nYou have the option to override certain connector properties by using the following message properties:\r\n\r\n- **QUERY** - This corresponds to **msg.config.query**.\r\n\r\n## Available Query Parameters:\r\n- **mode** : If you pass \"raw\" in mode, it will give you raw data (no modifications).\r\n- **panel** : If you are working for observability platform, we have panel query param for you.\r\n    Available Panels are:\r\n    - reported_injects\r\n\r\nIf you are passing panel, you are required to pass:\r\n- **from** : Starting time from which you want to retrieve data. (expected timestamp)\r\n- **to** : Ending time from which you want to retrieve data. (expected timestamp)\r\n\r\n`\r\nNote: Data will be modified as per the given panel name and sent as a response.\r\n`\r\n\r\n### Sample query object: \r\nFor instance, if you wish to retrieve injects without modifications, you can easily achieve this by including the \"mode=raw\" parameter in your query object.","category":"","in":[{"x":20,"y":80,"wires":[{"id":"99604e1384a32228"}]}],"out":[{"x":700,"y":80,"wires":[{"id":"84d82971d6f759d5","port":0}]},{"x":700,"y":80,"wires":[{"id":"84d82971d6f759d5","port":1}]}],"env":[{"name":"QUERY","type":"str","value":""}],"meta":{},"color":"#f3f3f3","icon":"ignite-connectors/igniteConnex.png"},{"id":"99604e1384a32228","type":"function","z":"4a06807022b84322","name":"API parameter setting","func":"let base_uri = env.get(\"IGNITE_API_BASE_URL\") || \"https://api.igniteconnex.io\"\nlet query = env.get(\"QUERY\") || msg.config.query || \"\";\n\nmsg.method = 'GET';\n\nmsg.url = `${base_uri}/monitor/api/v1/monitor/injects`;\n\nif (query) {\n    msg.url = `${msg.url}?${query}`\n};\n\nmsg.headers = {\n    \"x-ignite-api-secret\": env.get(\"IGNITE_API_SECRET\"),\n};\n\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[{"var":"_","module":"lodash"}],"x":200,"y":80,"wires":[["114f734a5200d869"]]},{"id":"114f734a5200d869","type":"http request","z":"4a06807022b84322","name":"request","method":"use","ret":"txt","paytoqs":"ignore","url":"","tls":"","persist":false,"proxy":"","insecureHTTPParser":false,"authType":"","senderr":false,"headers":[],"x":400,"y":80,"wires":[["84d82971d6f759d5"]]},{"id":"84d82971d6f759d5","type":"switch","z":"4a06807022b84322","name":"success ?","property":"statusCode","propertyType":"msg","rules":[{"t":"btwn","v":"199","vt":"num","v2":"299","v2t":"num"},{"t":"else"}],"checkall":"true","repair":false,"outputs":2,"x":560,"y":80,"wires":[[],[]]},{"id":"36f6bf0ac140bbd2","type":"subflow:4a06807022b84322","z":"c52e470e7ef6e459","name":"","x":450,"y":660,"wires":[["335e1b384f27ad0f"],["2a068f1cf38c3226"]]},{"id":"fca2ed2532ce6e11","type":"inject","z":"c52e470e7ef6e459","name":"","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":false,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":260,"y":660,"wires":[["36f6bf0ac140bbd2"]]},{"id":"335e1b384f27ad0f","type":"debug","z":"c52e470e7ef6e459","name":"debug 22","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","statusVal":"","statusType":"auto","x":640,"y":640,"wires":[]},{"id":"2a068f1cf38c3226","type":"debug","z":"c52e470e7ef6e459","name":"debug 23","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","statusVal":"","statusType":"auto","x":640,"y":680,"wires":[]}]

Overriding Connector Properties:

You have the option to override certain connector properties by using the following message properties:

  • QUERY - This corresponds to msg.config.query.

Available Query Parameters:

  • mode : If you pass "raw" in mode, it will give you raw data (no modifications).

  • panel : If you are working for observability platform, we have panel query param for you.
    Available Panels are:

    • reported_injects

    If you are passing panel, you are required to pass:

  • from : Starting time from which you want to retrieve data. (expected timestamp)

  • to : Ending time from which you want to retrieve data. (expected timestamp)

Note: Data will be modified as per the given panel name and sent as a response.