|
13 | 13 | from influxdb import line_protocol
|
14 | 14 | import pandas as pd
|
15 | 15 |
|
| 16 | + |
16 | 17 | class TestLineProtocol(unittest.TestCase):
|
17 | 18 | """Define the LineProtocol test object."""
|
18 | 19 |
|
@@ -55,43 +56,44 @@ def test_timezone(self):
|
55 | 56 | eastern = berlin.astimezone(timezone('US/Eastern'))
|
56 | 57 | # pandas ns timestamp tests
|
57 | 58 | pddt = pd.Timestamp('2009-11-10 23:00:00.123456789')
|
58 |
| - pdutc = pd.Timestamp(pddt, tz = 'UTC') |
| 59 | + pdutc = pd.Timestamp(pddt, tz='UTC') |
59 | 60 | pdberlin = pdutc.astimezone('Europe/Berlin')
|
60 | 61 | pdeastern = pdberlin.astimezone('US/Eastern')
|
61 | 62 |
|
62 |
| - data = { "points": [ |
63 |
| - {"measurement": "A", "fields": {"val": 1}, |
64 |
| - "time": 0}, |
65 |
| - #string representations |
66 |
| - {"measurement": "A", "fields": {"val": 1}, |
67 |
| - "time": "2009-11-10T23:00:00.123456Z"}, # String version for datetime |
68 |
| - {"measurement": "A", "fields": {"val": 1}, |
69 |
| - "time": "2009-11-10 23:00:00.123456789"}, # String version for pandas ns timestamp |
70 |
| - # datetime |
71 |
| - {"measurement": "A", "fields": {"val": 1}, "time": dt}, |
72 |
| - {"measurement": "A", "fields": {"val": 1}, "time": utc}, |
73 |
| - {"measurement": "A", "fields": {"val": 1}, "time": berlin}, |
74 |
| - {"measurement": "A", "fields": {"val": 1}, "time": eastern}, |
75 |
| - # pandas timestamp |
76 |
| - {"measurement": "A", "fields": {"val": 1}, "time": pddt}, |
77 |
| - {"measurement": "A", "fields": {"val": 1}, "time": pdutc}, |
78 |
| - {"measurement": "A", "fields": {"val": 1}, "time": pdberlin}, |
79 |
| - {"measurement": "A", "fields": {"val": 1}, "time": pdeastern}, |
80 |
| - ]} |
81 |
| - |
| 63 | + data = {"points": [ |
| 64 | + {"measurement": "A", "fields": {"val": 1}, "time": 0}, |
| 65 | + # string representations |
| 66 | + # String version for datetime |
| 67 | + {"measurement": "A", "fields": {"val": 1}, |
| 68 | + "time": "2009-11-10T23:00:00.123456Z"}, |
| 69 | + # String version for pandas ns timestamp |
| 70 | + {"measurement": "A", "fields": {"val": 1}, |
| 71 | + "time": "2009-11-10 23:00:00.123456789"}, |
| 72 | + # datetime |
| 73 | + {"measurement": "A", "fields": {"val": 1}, "time": dt}, |
| 74 | + {"measurement": "A", "fields": {"val": 1}, "time": utc}, |
| 75 | + {"measurement": "A", "fields": {"val": 1}, "time": berlin}, |
| 76 | + {"measurement": "A", "fields": {"val": 1}, "time": eastern}, |
| 77 | + # pandas timestamp |
| 78 | + {"measurement": "A", "fields": {"val": 1}, "time": pddt}, |
| 79 | + {"measurement": "A", "fields": {"val": 1}, "time": pdutc}, |
| 80 | + {"measurement": "A", "fields": {"val": 1}, "time": pdberlin}, |
| 81 | + {"measurement": "A", "fields": {"val": 1}, "time": pdeastern}, |
| 82 | + ] |
| 83 | + } |
82 | 84 |
|
83 | 85 | self.assertEqual(
|
84 | 86 | line_protocol.make_lines(data),
|
85 | 87 | '\n'.join([
|
86 | 88 | 'A val=1i 0',
|
87 | 89 | 'A val=1i 1257894000123456000',
|
88 | 90 | 'A val=1i 1257894000123456789',
|
89 |
| - #datetime results |
| 91 | + # datetime results |
90 | 92 | 'A val=1i 1257894000123456000',
|
91 | 93 | 'A val=1i 1257894000123456000',
|
92 | 94 | 'A val=1i 1257890400123456000',
|
93 | 95 | 'A val=1i 1257890400123456000',
|
94 |
| - #pandas ns timestamp results |
| 96 | + # pandas ns timestamp results |
95 | 97 | 'A val=1i 1257894000123456789',
|
96 | 98 | 'A val=1i 1257894000123456789',
|
97 | 99 | 'A val=1i 1257894000123456789',
|
|
0 commit comments