OPC UA and Databricks Integration

<pre><code class="language-toml"> [[inputs.opcua]] ## Metric name # name = "opcua" # ## OPC UA Endpoint URL # endpoint = "opc.tcp://localhost:4840" # ## Maximum time allowed to establish a connect to the endpoint. # connect_timeout = "10s" # ## Maximum time allowed for a request over the established connection. # request_timeout = "5s" # Maximum time that a session shall remain open without activity. # session_timeout = "20m" # ## Security policy, one of "None", "Basic128Rsa15", "Basic256", ## "Basic256Sha256", or "auto" # security_policy = "auto" # ## Security mode, one of "None", "Sign", "SignAndEncrypt", or "auto" # security_mode = "auto" # ## Path to cert.pem. Required when security mode or policy isn't "None". ## If cert path is not supplied, self-signed cert and key will be generated. # certificate = "/etc/telegraf/cert.pem" # ## Path to private key.pem. Required when security mode or policy isn't "None". ## If key path is not supplied, self-signed cert and key will be generated. # private_key = "/etc/telegraf/key.pem" # ## Authentication Method, one of "Certificate", "UserName", or "Anonymous". To ## authenticate using a specific ID, select 'Certificate' or 'UserName' # auth_method = "Anonymous" # ## Username. Required for auth_method = "UserName" # username = "" # ## Password. Required for auth_method = "UserName" # password = "" # ## Option to select the metric timestamp to use. Valid options are: ## "gather" -- uses the time of receiving the data in telegraf ## "server" -- uses the timestamp provided by the server ## "source" -- uses the timestamp provided by the source # timestamp = "gather" # ## Client trace messages ## When set to true, and debug mode enabled in the agent settings, the OPCUA ## client's messages are included in telegraf logs. These messages are very ## noisey, but essential for debugging issues. # client_trace = false # ## Include additional Fields in each metric ## Available options are: ## DataType -- OPC-UA Data Type (string) # optional_fields = [] # ## Node ID configuration ## name - field name to use in the output ## namespace - OPC UA namespace of the node (integer value 0 thru 3) ## identifier_type - OPC UA ID type (s=string, i=numeric, g=guid, b=opaque) ## identifier - OPC UA ID (tag as shown in opcua browser) ## tags - extra tags to be added to the output metric (optional); deprecated in 1.25.0; use default_tags ## default_tags - extra tags to be added to the output metric (optional) ## ## Use either the inline notation or the bracketed notation, not both. # ## Inline notation (default_tags not supported yet) # nodes = [ # {name="", namespace="", identifier_type="", identifier="", tags=[["tag1", "value1"], ["tag2", "value2"]}, # {name="", namespace="", identifier_type="", identifier=""}, # ] # ## Bracketed notation # [[inputs.opcua.nodes]] # name = "node1" # namespace = "" # identifier_type = "" # identifier = "" # default_tags = { tag1 = "value1", tag2 = "value2" } # # [[inputs.opcua.nodes]] # name = "node2" # namespace = "" # identifier_type = "" # identifier = "" # ## Node Group ## Sets defaults so they aren't required in every node. ## Default values can be set for: ## * Metric name ## * OPC UA namespace ## * Identifier ## * Default tags ## ## Multiple node groups are allowed #[[inputs.opcua.group]] ## Group Metric name. Overrides the top level name. If unset, the ## top level name is used. # name = # ## Group default namespace. If a node in the group doesn't set its ## namespace, this is used. # namespace = # ## Group default identifier type. If a node in the group doesn't set its ## namespace, this is used. # identifier_type = # ## Default tags that are applied to every node in this group. Can be ## overwritten in a node by setting a different value for the tag name. ## example: default_tags = { tag1 = "value1" } # default_tags = {} # ## Node ID Configuration. Array of nodes with the same settings as above. ## Use either the inline notation or the bracketed notation, not both. # ## Inline notation (default_tags not supported yet) # nodes = [ # {name="node1", namespace="", identifier_type="", identifier=""}, # {name="node2", namespace="", identifier_type="", identifier=""}, #] # ## Bracketed notation # [[inputs.opcua.group.nodes]] # name = "node1" # namespace = "" # identifier_type = "" # identifier = "" # default_tags = { tag1 = "override1", tag2 = "value2" } # # [[inputs.opcua.group.nodes]] # name = "node2" # namespace = "" # identifier_type = "" # identifier = "" ## Enable workarounds required by some devices to work correctly # [inputs.opcua.workarounds] ## Set additional valid status codes, StatusOK (0x0) is always considered valid # additional_valid_status_codes = ["0xC0"] # [inputs.opcua.request_workarounds] ## Use unregistered reads instead of registered reads # use_unregistered_reads = false </code></pre>

<pre><code class="language-toml">[[outputs.http]] ## Databricks SQL Statement Execution API endpoint url = "https://{{ env "DATABRICKS_HOST" }}/api/2.0/sql/statements" ## Use POST to submit each Telegraf batch as a SQL request method = "POST" ## Personal-access token (PAT) for workspace or service principal headers = { Authorization = "Bearer {{ env "DATABRICKS_TOKEN" }}" } ## Send JSON that wraps the metrics batch in a SQL INSERT (or PUT into a Volume) content_type = "application/json" ## Serialize metrics as JSON so they can be embedded in the SQL statement data_format = "json" json_timestamp_units = "1ms" ## Build the request body. Telegraf replaces the template variables at runtime. ## Example inserts a row per metric into a Unity-Catalog table. body_template = """ { \"statement\": \"INSERT INTO ${TARGET_TABLE} VALUES {{range .Metrics}}(from_unixtime({{.timestamp}}/1000), {{.fields.usage}}, '{{.tags.host}}'){{end}}\", \"warehouse_id\": \"${WAREHOUSE_ID}\" } """ ## Optional: add batching limits or TLS settings # batch_size = 500 # timeout = "10s" </code></pre>