Analytics

import json from pprint import pprint import urllib3 from litmussdk import analytics urllib3 disable warnings(urllib3 exceptions insecurerequestwarning) if name == " main " sample processor defined name = "apigenerator" sample processor search name = "generator" sample processor group = "apicreatedgroup" datahub subscribe search name = "datahub subscribe" datahub publish search name = "datahub publish" \## list all functions print(" \nfunctions\n ") pprint(analytics list all functions()) \## list all groups print(" \nlist groups\n ") pprint(analytics list all groups()) \## list all processors print(" \nlist processors\n ") pprint(analytics list all processors()) \## list processor library print(" \nprocessor library\n ") pprint(analytics list all in processor library()) \## get prometheus metrics print(" \nmetrics\n ") pprint(analytics analytics prometheus metrics()) \## create datahub subscribe processor print(" \ndh subscribe\n ") ( internal function name, parameters, ) = analytics get single processor from library(datahub subscribe search name) , datahub subscribe id = analytics create processor( sample processor defined name, internal function name, parameters, true, sample processor group, ) print(datahub subscribe id) datahub subscribe id = json loads(datahub subscribe id)\["id"] \## list name and parameter of a processor print(" \nname and parameter\n ") ( internal function name, parameters, ) = analytics get single processor from library(datahub publish search name) pprint(internal function name) pprint(parameters) \## create datahub publish print(" \ndh publish\n ") code, datahub publish id = analytics create processor( sample processor defined name, internal function name, parameters, true, sample processor group, ) print(code, datahub publish id) datahub publish id = json loads(datahub publish id)\["id"] \## connect processors print(" \nconnect\n ") analytics connect processor("events", \[datahub subscribe id], \[datahub publish id]) \## delete all processors print(" \ndelete all\n ") analytics remove all processors()