Contents
Cirrus Link Resources
Cirrus Link Website
Contact Us (Sales/Support)
Forum
Cirrus Link Modules Docs for Ignition 7.9.x
Inductive Resources
Ignition User Manual
Knowledge Base Articles
Inductive University
Forum
...
IoT Bridge for Snowflake (IBSNOW) is an application that connects to an MQTT Server (such as Chariot MQTT Server or AWS IoT Core) and consumes MQTT Sparkplug messages from Edge devices.
When these messages are formatted as Sparkplug Templates, as defined in the Sparkplug Specification, the templates are used to create the data in Snowflake automatically with no additional coding or configuration.
Warning |
---|
If the messages do not use templates, they will be stored in a database table as unprocessed messages and additional work will be required to use this data in Snowflake. |
...
When complete, it should look similar to what is shown below.
ibsnow.properties
# The IBSNOW instance friendly name. If ommitted, it will become 'IBSNOW-vm ec2-instance-id' the VM is located in #ibsnow the IoT Bridge for Snowflake instance is in= East US # The MQTT Server URL mqtt_server_url = ssl: //55.23.12.33 :8883 # The MQTT Server name mqtt_server_name = Chariot MQTT Server # The MQTT username (if required by the MQTT Server) mqtt_username = admin # The MQTT password (if required by the MQTT Server) mqtt_password = changeme # The MQTT keep-alive timeout in seconds #mqtt_keepalive_timeout = 30 # The path to the TLS Certificate Authority certificate chain #mqtt_ca_cert_chain_path = # The path to the TLS certificate #mqtt_client_cert_path = # The path to the TLS private key #mqtt_client_private_key_path = # The TLS private key password #mqtt_client_private_key_password = # Whether or not to verify the hostname against the server certificate #mqtt_verify_hostname = false # The Sparkplug sequence reordering timeout in milliseconds sequence_reordering_timeout = 5000 # Whether or not to block auto-rebirth requests #block_auto_rebirth = false # The primary host ID if this is the acting primary host primary_host_id = IamHost # The MQTT Client ID - It is recommend to not set this unless there is a specific reason to do so. If this is not set a random client ID will be automatically generated #client_id = # Snowflake streaming connection properties - A custom client name for the connection (e.g. MyClient) snowflake_streaming_client_name = MY_CLIENT # Snowflake streaming connection properties - A custom channel name for the connection (e.g. MyChannel) # If this is left blank/empty, Channel names of the Sparkplug Group ID will be used instead of a single channel #snowflake_streaming_channel_name = # Snowflake streaming connection properties - The Table name associated with the Database and Schema already provisioned in the Snowflake account (e.g. MyTable) snowflake_streaming_table_name = SPARKPLUG_RAW # Snowflake notify connection properties - The Database name associated with the connection that is already provisioned in the Snowflake account (e.g. MyDb) snowflake_notify_db_name = cl_bridge_node_db # Snowflake notify connection properties - The Schema name associated with the Database already provisioned in the Snowflake account (e.g. PUBLIC) snowflake_notify_schema_name = stage_db # Snowflake notify connection properties - The Warehouse name associated with the notifications already provisioned in the Snowflake account (e.g. PUBLIC) snowflake_notify_warehouse_name = cl_bridge_ingest_wh # Whether or not to send notification tasks to Snowflake based on incoming Sparkplug = us-east-1 # The number of milliseconds to delay after receiving an NBIRTH before notifying Snowflake over the event (requires snowflake_notify_task_enabled is true)
|
Now, modify the file /opt/ibsnow/conf/snowflake_streaming_profile.json file. Set the following:
...