ClearBlade provides a native integration for high-performance interactions with Google Pub/Sub. This is idea ideal for sending MQTT messages into the Google Cloud services or for integrating data from other Google Cloud services directly with your ClearBlade application.
...
Code Block |
---|
{ "credentials_map": { // This is the service account JSON object "type": "service_account", "project_id": "myprojectid", "private_key_id": "blahblahblah", "private_key": "<priv_key>", "client_email": "a@a.com", "client_id": "9126871624161341", "auth_uri": "https://accounts.google.com/o/oauth2/auth", "token_uri": "https://oauth2.googleapis.com/token", "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs", "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/dahjkdhajkd%40dajsdgajdadsad.iam.gserviceaccount.com" }, "project_id": "myprojectid", "topics": [ // This is to send data to Google Pub/Sub {"path": "iotdemo"}, // Non IoT Core topic {"path": "/devices/+/events", "type": 1, "target": "performance-testing"}, // IoT Core topic {"path": "/devices/+/events/sub", "type": 1, "target": "performance-testing-sub", "sub_folder": "sub"}, // IoT Core topic {"path": "/devices/+/state", "type": 2, "target": "performance-testing-state"} // IoT Core topic ], "forwarders": { // This is to receive Google Pub/Sub messages "ack_strategy": 0, "poll_rate": 5000, //Deprecated after 9.36.x (ignored if included) "max_messages_per_poll": 2, //Deprecated after 9.36.x (ignored if included) "subscriptions": [ { "mqtt_topic": "pubsub", "pubsub_subscription": "test-sub" } ] } } |
path
is the MQTT topic on the ClearBlade broker that the Pub/Sub client will subscribe to internally to the ClearBlade broker. . For Non IoT Core integrations, path must match the Google Pub/Sub topic being published to exactly. Hence, in this case path cannot contain wildcards (+, #).type
is the topic type. No type represents a non-IoT Core topic. 1 is for event
and 2 is for state
. For Non IoT Core integrations, type is not used.target
is the Google Pub/Sub topic the Pub/Sub client will publish to in Pub/Sub. sub_folder
is for the event's topic if it has a subfolder. For Non IoT Core integrations, target is not used.
GET:
No query support. Admin or Dev.
...
ack_strategy: 0 = ack immediately, 1 = never ack. For now, 0 should always be used.
poll_rate: Time (ms) between sending message batches to the broker. 0 will send messages immediately (deprecated after 9.36.x - ignored if included)
max_messages_per_poll: Max number of messages to send in a single batch to the broker. Implicit minimum value of 1 (deprecated after 9.36.x - ignored if included)
Messages are received by ClearBlade as soon as possible from Google. ClearBlade will buffer them internally and send them in batches as defined above.