bintopia.com - BlackDragon

Linux iai.iais.com.au 3.10.0-957.27.2.el7.x86_64 #1 SMP Mon Jul 29 17:46:05 UTC 2019 x86_64
Apache
221.121.155.106
78 Domain

URL to Upload

File Name

Upload Method

Upload from URL

File Name : line_protocol.py

# -*- coding: utf-8 -*-

from __future__ import absolute_import
from __future__ import division
from __future__ import print_function
from __future__ import unicode_literals

from datetime import datetime
from numbers import Integral

from pytz import UTC
from dateutil.parser import parse
from six import iteritems, binary_type, text_type, integer_types, PY2

EPOCH = UTC.localize(datetime.utcfromtimestamp(0))

def _convert_timestamp(timestamp, precision=None):
    if isinstance(timestamp, Integral):
        return timestamp  # assume precision is correct if timestamp is int
    if isinstance(_get_unicode(timestamp), text_type):
        timestamp = parse(timestamp)
    if isinstance(timestamp, datetime):
        if not timestamp.tzinfo:
            timestamp = UTC.localize(timestamp)
        ns = (timestamp - EPOCH).total_seconds() * 1e9
        if precision is None or precision == 'n':
            return ns
        elif precision == 'u':
            return ns / 1e3
        elif precision == 'ms':
            return ns / 1e6
        elif precision == 's':
            return ns / 1e9
        elif precision == 'm':
            return ns / 1e9 / 60
        elif precision == 'h':
            return ns / 1e9 / 3600
    raise ValueError(timestamp)

def _escape_tag(tag):
    tag = _get_unicode(tag, force=True)
    return tag.replace(
        "\\", "\\\\"
    ).replace(
        " ", "\\ "
    ).replace(
        ",", "\\,"
    ).replace(
        "=", "\\="
    )

def quote_ident(value):
    return "\"{0}\"".format(
        value.replace(
            "\\", "\\\\"
        ).replace(
            "\"", "\\\""
        ).replace(
            "\n", "\\n"
        )
    )

def quote_literal(value):
    return "'{0}'".format(
        value.replace(
            "\\", "\\\\"
        ).replace(
            "'", "\\'"
        )
    )

def _is_float(value):
    try:
        float(value)
    except ValueError:
        return False
    return True

def _escape_value(value):
    value = _get_unicode(value)
    if isinstance(value, text_type) and value != '':
        return quote_ident(value)
    elif isinstance(value, integer_types) and not isinstance(value, bool):
        return str(value) + 'i'
    elif _is_float(value):
        return repr(value)
    else:
        return str(value)

def _get_unicode(data, force=False):
    """
    Try to return a text aka unicode object from the given data.
    """
    if isinstance(data, binary_type):
        return data.decode('utf-8')
    elif data is None:
        return ''
    elif force:
        if PY2:
            return unicode(data)
        else:
            return str(data)
    else:
        return data

def make_lines(data, precision=None):
    """
    Extracts the points from the given dict and returns a Unicode string
    matching the line protocol introduced in InfluxDB 0.9.0.
    """
    lines = []
    static_tags = data.get('tags')
    for point in data['points']:
        elements = []

# add measurement name
        measurement = _escape_tag(_get_unicode(
            point.get('measurement', data.get('measurement'))
        ))
        key_values = [measurement]

# add tags
        if static_tags:
            tags = dict(static_tags)  # make a copy, since we'll modify
            tags.update(point.get('tags') or {})
        else:
            tags = point.get('tags') or {}

# tags should be sorted client-side to take load off server
        for tag_key, tag_value in sorted(iteritems(tags)):
            key = _escape_tag(tag_key)
            value = _escape_tag(tag_value)

if key != '' and value != '':
                key_values.append(key + "=" + value)
        key_values = ','.join(key_values)
        elements.append(key_values)

# add fields
        field_values = []
        for field_key, field_value in sorted(iteritems(point['fields'])):
            key = _escape_tag(field_key)
            value = _escape_value(field_value)
            if key != '' and value != '':
                field_values.append(key + "=" + value)
        field_values = ','.join(field_values)
        elements.append(field_values)

# add timestamp
        if 'time' in point:
            timestamp = _get_unicode(str(int(
                _convert_timestamp(point['time'], precision)
            )))
            elements.append(timestamp)

line = ' '.join(elements)
        lines.append(line)
    lines = '\n'.join(lines)
    return lines + '\n'

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	drwxr-xr-x	2017-07-25 12:18:10
..	dir	-	root/root	drwxr-xr-x	2025-11-12 02:25:25
influxdb08	dir	-	root/root	drwxr-xr-x	2017-07-25 12:18:10
tests	dir	-	root/root	drwxr-xr-x	2017-07-25 12:18:10
__init__.py	file	394 B	root/root	-rw-r--r--	2017-06-06 08:35:03
__init__.pyc	file	654 B	root/root	-rw-r--r--	2017-07-25 12:18:10
_dataframe_client.py	file	15 KB	root/root	-rw-r--r--	2017-06-06 08:35:03
_dataframe_client.pyc	file	10.5 KB	root/root	-rw-r--r--	2017-07-25 12:18:10
chunked_json.py	file	604 B	root/root	-rw-r--r--	2017-06-06 08:35:03
chunked_json.pyc	file	825 B	root/root	-rw-r--r--	2017-07-25 12:18:10
client.py	file	29.74 KB	root/root	-rw-r--r--	2017-06-06 08:35:03
client.pyc	file	29.9 KB	root/root	-rw-r--r--	2017-07-25 12:18:10
dataframe_client.py	file	645 B	root/root	-rw-r--r--	2017-06-06 08:35:03
dataframe_client.pyc	file	1.12 KB	root/root	-rw-r--r--	2017-07-25 12:18:10
exceptions.py	file	825 B	root/root	-rw-r--r--	2017-06-06 08:35:03
exceptions.pyc	file	1.49 KB	root/root	-rw-r--r--	2017-07-25 12:18:10
helper.py	file	6.17 KB	root/root	-rw-r--r--	2017-06-06 08:35:03
helper.pyc	file	6.38 KB	root/root	-rw-r--r--	2017-07-25 12:18:10
line_protocol.py	file	4.38 KB	root/root	-rw-r--r--	2017-06-06 08:35:03
line_protocol.pyc	file	4.55 KB	root/root	-rw-r--r--	2017-07-25 12:18:10
resultset.py	file	6.13 KB	root/root	-rw-r--r--	2017-06-06 08:35:03
resultset.pyc	file	6.93 KB	root/root	-rw-r--r--	2017-07-25 12:18:10