arena.device

class Device(arena.arena_mqtt.ArenaMQTT):

Gives access to an ARENA device. Can create and execute various user-defined functions/tasks.

str host: Hostname of the ARENA webserver (required).
str realm: Reserved topic fork for future use (optional).
str namespace: Username of authenticated user or other namespace (automatic).
str device: The name of the device, without namespace (required).
int network_latency_interval: Interval (in ms) to run network graph latency update. Default value is 10000 (10 secs). Ignore this parameter.
func on_msg_callback: Called on all MQTT messages received. Default = None.
func end_program_callback: Called on MQTT disconnect. Default = None.
bool debug: If true, print a log of all publish messages from this client. Default = False.

Device( host='arenaxr.org', realm='realm', network_latency_interval=10000, on_msg_callback=None, end_program_callback=None, debug=False, **kwargs)

async def process_message(self):

def publish(self, topic, payload_obj):

Publishes to mqtt broker.

def on_publish(self, client, userdata, mid):

arena.arena_mqtt.ArenaMQTT: scene; device; auth; debug; username; remote_auth_token; mqttc_id; config_url; config_data; mqtt_host; topicParams; latency_topic; ignore_topic; can_publish_obj; mqttc; on_msg_callback; end_program_callback; event_loop; mqtt_connect_evt; subscriptions; msg_queue; generate_client_id; network_latency_update; run_once; run_after_interval; run_async; run_forever; run_tasks; stop_tasks; sleep; on_connect; do_subscribe; on_message; on_message_private; on_subscribe; on_disconnect; disconnect; message_callback_add; message_callback_remove; rcv_queue_len; pub_queue_len; client_id

Table of contents