GPUdb.create_table_monitor( table_name = None, options = {} )
Creates a monitor that watches for new records inserted into a particular table (identified by input parameter table_name) and forwards copies to subscribers via ZMQ. After this call completes, subscribe to the returned output parameter topic_id on the ZMQ table monitor port (default 9002). Each time an insert operation on the table completes, a multipart message is published for that topic; the first part contains only the topic ID, and each subsequent part contains one binary-encoded Avro object that was inserted. The monitor will continue to run (regardless of whether or not there are any subscribers) until deactivated with clear_table_monitor.
Input Parameter Description
| Name | Type | Description |
|---|---|---|
| table_name | str | Name of the table to monitor. Must not refer to a collection. |
| options | dict of str | Optional parameters. Default value is an empty dict ( {} ). |
Output Parameter Description
| Name | Type | Description |
|---|---|---|
| topic_id | str | The ZMQ topic ID to subscribe to for inserted records. |
| table_name | str | Value of input parameter table_name. |
| type_schema | str | JSON Avro schema of the table, for use in decoding published records. |