Skip to content

Wavefront, Influx, OpenTSDB DCC and packages for wavefront,influx,opentsdb.#5

Open
lucifercr07 wants to merge 12 commits into
KohliDev:masterfrom
lucifercr07:tsdb
Open

Wavefront, Influx, OpenTSDB DCC and packages for wavefront,influx,opentsdb.#5
lucifercr07 wants to merge 12 commits into
KohliDev:masterfrom
lucifercr07:tsdb

Conversation

@lucifercr07

@lucifercr07 lucifercr07 commented Sep 22, 2017

Copy link
Copy Markdown
Collaborator

Added wavefront, influx, opentsdb DCCs and packages for wavefront, influx, opentsdb along with them examples for the DCCs.

@lucifercr07 lucifercr07 changed the title Wavefront, Influx DCC and packages for wavefront,influx. Wavefront, Influx, OpenTSDB DCC and packages for wavefront,influx,opentsdb. Sep 27, 2017
Comment thread liota/dccs/influx.py
metric_unit = str(reg_metric.ref_entity.unit)
metric_unit = ''.join(metric_unit.split())
message += '{0},unit={5},host={1} {2}={3} {4}'.format(device_name,host,metric_name,v[1],
v[0]*1000000,metric_unit)

Copy link
Copy Markdown
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Declare it as common variabale.

Comment thread liota/dccs/influx.py

def _format_data(self, reg_metric):
met_cnt = reg_metric.values.qsize()
message = ''

Copy link
Copy Markdown
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

explain this piece

Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

For replacing message as None, https://stackoverflow.com/a/1398628/4134429 as per this stack answer we should go with None, Should I go ahead and change this to None?

Comment thread packages/influx.py
# Encapsulate QoS related parameters
qos_details = QoSDetails(config['in_flight'], config['queue_size'], config['retry'])

# Connecting to emqtt broker

Copy link
Copy Markdown
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

MQTT not EMQTT

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants