def create_latency_tags(whid): logger = system.util.getLogger("%s-Create-Latency-Tags" % (whid)) if whid != "" and whid != None: provider = "[%s_SCADA_TAG_PROVIDER]" % (whid) tag_paths = {"avg_latency":{"name":"avg_latency", "valueSource": "memory", "dataType": "String", "value" : ""}, "aws_data_copy":{"name":"aws_data_copy", "valueSource": "reference", "dataType": "String", "sourceTagPath": "[~]System/aws_data.value"}, "first_pass":{"name":"first_pass", "valueSource": "memory", "dataType": "Boolean", "value" : True}, "last_alarm_change_ts":{"name":"last_alarm_change_ts", "valueSource": "memory", "dataType": "DateTime", "formatString": "yyyy-MM-dd h:mm:ss aa"}, "prev_key":{"name":"prev_key", "valueSource": "memory", "dataType": "String", "value" : ""}, "rolling_latency":{"name":"rolling_latency", "valueSource": "memory", "dataType": "StringArray", "alarmEvalEnabled": True, "value": [ "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0" ],}} for k,v in tag_paths.items(): if not system.tag.exists("%sLatency/%s" % (provider, k)): base_path = "%s/Latency" % (provider) system.tag.configure(base_path, v) logger.info("Created tag %s" % (k))