From bb8e37ec36c3dfc1a48528b14a5b1ad5c6745270 Mon Sep 17 00:00:00 2001 From: karel rehor Date: Wed, 11 Sep 2024 17:23:36 +0200 Subject: [PATCH 1/9] docs: (WIP) updating batching_example.py --- Examples/batching_example.py | 214 +++++++++++++++++++---------------- 1 file changed, 119 insertions(+), 95 deletions(-) diff --git a/Examples/batching_example.py b/Examples/batching_example.py index 4cef29b..85b3b93 100644 --- a/Examples/batching_example.py +++ b/Examples/batching_example.py @@ -6,109 +6,133 @@ import influxdb_client_3 as InfluxDBClient3 from influxdb_client_3 import write_client_options, WritePrecision, WriteOptions, InfluxDBError +from config import Config + class BatchingCallback(object): + def __init__(self): + self.write_status_msg = None + self.write_count = 0 + self.retry_count = 0 + def success(self, conf, data: str): print(f"Written batch: {conf}, data: {data}") + self.write_count += 1 + self.write_status_msg = f"SUCCESS: {self.write_count} writes" def error(self, conf, data: str, exception: InfluxDBError): print(f"Cannot write batch: {conf}, data: {data} due: {exception}") + self.write_status_msg = f"FAILURE - cause: {exception}" def retry(self, conf, data: str, exception: InfluxDBError): print(f"Retryable error occurs for batch: {conf}, data: {data} retry: {exception}") - - -# Creating 5.000 gatewayId values as MongoDB ObjectIDs -gatewayIds = [ObjectId() for x in range(0, 100)] - -# Setting decimal precision to 2 -precision = 2 - -# Setting timestamp for first sensor reading -now = datetime.datetime.now() -now = now - datetime.timedelta(days=30) -teststart = datetime.datetime.now() - -# InfluxDB connection details -token = "" -org = "" -database = "" -url = "eu-central-1-1.aws.cloud2.influxdata.com" - -callback = BatchingCallback() - -write_options = WriteOptions(batch_size=5_000, - flush_interval=10_000, - jitter_interval=2_000, - retry_interval=5_000, - max_retries=5, - max_retry_delay=30_000, - exponential_base=2) - -wco = write_client_options(success_callback=callback.success, - error_callback=callback.error, - retry_callback=callback.retry, - write_options=write_options - ) -# Opening InfluxDB client with a batch size of 5k points or flush interval -# of 10k ms and gzip compression -with InfluxDBClient3.InfluxDBClient3(token=token, - host=url, - org=org, - database=database, enable_gzip=True, write_client_options=wco) as _client: - # Creating iterator for one hour worth of data (6 sensor readings per - # minute) - for i in range(0, 525600): - # Adding 10 seconds to timestamp of previous sensor reading - now = now + datetime.timedelta(seconds=10) - # Iterating over gateways - for gatewayId in gatewayIds: - # Creating random test data for 12 fields to be stored in - # timeseries database - bcW = random.randrange(1501) - bcWh = round(random.uniform(0, 4.17), precision) - bdW = random.randrange(71) - bdWh = round(random.uniform(0, 0.12), precision) - cPvWh = round(random.uniform(0.51, 27.78), precision) - cW = random.randrange(172, 10001) - cWh = round(random.uniform(0.51, 27.78), precision) - eWh = round(random.uniform(0, 41.67), precision) - iWh = round(random.uniform(0, 16.67), precision) - pW = random.randrange(209, 20001) - pWh = round(random.uniform(0.58, 55.56), precision) - scWh = round(random.uniform(0.58, 55.56), precision) - # Creating point to be ingested into InfluxDB - p = InfluxDBClient3.Point("stream").tag( - "gatewayId", - str(gatewayId)).field( - "bcW", - bcW).field( - "bcWh", - bcWh).field( - "bdW", - bdW).field( - "bdWh", - bdWh).field( - "cPvWh", - cPvWh).field( - "cW", - cW).field( - "cWh", - cWh).field( - "eWh", - eWh).field( - "iWh", - iWh).field( - "pW", - pW).field( - "pWh", - pWh).field( - "scWh", - scWh).time( - now.strftime('%Y-%m-%dT%H:%M:%SZ'), - WritePrecision.S) - - # Writing point (InfluxDB automatically batches writes into sets of - # 5k points) - _client.write(record=p) + self.retry_count += 1 + + +def main() -> None: + conf = Config() + + # Creating 5.000 gatewayId values as MongoDB ObjectIDs + gatewayIds = [ObjectId() for x in range(0, 100)] + + # Setting decimal precision to 2 + precision = 2 + + # Setting timestamp for first sensor reading + now = datetime.datetime.now() + now = now - datetime.timedelta(days=30) + teststart = datetime.datetime.now() + + # InfluxDB connection details + token = "" + org = "" + database = "" + url = "eu-central-1-1.aws.cloud2.influxdata.com" + + callback = BatchingCallback() + + write_options = WriteOptions(batch_size=5_000, + flush_interval=10_000, + jitter_interval=2_000, + retry_interval=5_000, + max_retries=5, + max_retry_delay=30_000, + exponential_base=2) + + wco = write_client_options(success_callback=callback.success, + error_callback=callback.error, + retry_callback=callback.retry, + write_options=write_options) + + # Opening InfluxDB client with a batch size of 5k points or flush interval + # of 10k ms and gzip compression + with InfluxDBClient3.InfluxDBClient3(token=conf.token, + host=conf.host, + org=conf.org, + database=conf.database, + enable_gzip=True, + write_client_options=wco) as _client: + # Creating iterator for one hour worth of data (6 sensor readings per + # minute) + # for i in range(0, 525600): + for i in range(0, 52600): + # Adding 10 seconds to timestamp of previous sensor reading + now = now + datetime.timedelta(seconds=10) + # Iterating over gateways + for gatewayId in gatewayIds: + # Creating random test data for 12 fields to be stored in + # timeseries database + bcW = random.randrange(1501) + bcWh = round(random.uniform(0, 4.17), precision) + bdW = random.randrange(71) + bdWh = round(random.uniform(0, 0.12), precision) + cPvWh = round(random.uniform(0.51, 27.78), precision) + cW = random.randrange(172, 10001) + cWh = round(random.uniform(0.51, 27.78), precision) + eWh = round(random.uniform(0, 41.67), precision) + iWh = round(random.uniform(0, 16.67), precision) + pW = random.randrange(209, 20001) + pWh = round(random.uniform(0.58, 55.56), precision) + scWh = round(random.uniform(0.58, 55.56), precision) + # Creating point to be ingested into InfluxDB + p = InfluxDBClient3.Point("stream").tag( + "gatewayId", + str(gatewayId)).field( + "bcW", + bcW).field( + "bcWh", + bcWh).field( + "bdW", + bdW).field( + "bdWh", + bdWh).field( + "cPvWh", + cPvWh).field( + "cW", + cW).field( + "cWh", + cWh).field( + "eWh", + eWh).field( + "iWh", + iWh).field( + "pW", + pW).field( + "pWh", + pWh).field( + "scWh", + scWh).time( + now.strftime('%Y-%m-%dT%H:%M:%SZ'), + WritePrecision.S) + + # Writing point (InfluxDB automatically batches writes into sets of + # 5k points) + _client.write(record=p) + + print(callback.write_status_msg) + print(f"Write retries: {callback.retry_count}") + + +if __name__ == "__main__": + main() \ No newline at end of file From 5edd51b180b71837038281ceee8a695f0651e57f Mon Sep 17 00:00:00 2001 From: karel rehor Date: Thu, 12 Sep 2024 13:17:02 +0200 Subject: [PATCH 2/9] fix: 103 - adding properties to measure and control run. --- Examples/batching_example.py | 23 +++++++++++++---------- 1 file changed, 13 insertions(+), 10 deletions(-) diff --git a/Examples/batching_example.py b/Examples/batching_example.py index 85b3b93..247c7ea 100644 --- a/Examples/batching_example.py +++ b/Examples/batching_example.py @@ -1,5 +1,6 @@ import datetime import random +import time from bson import ObjectId @@ -15,6 +16,7 @@ def __init__(self): self.write_status_msg = None self.write_count = 0 self.retry_count = 0 + self.start = time.time_ns() def success(self, conf, data: str): print(f"Written batch: {conf}, data: {data}") @@ -29,6 +31,9 @@ def retry(self, conf, data: str, exception: InfluxDBError): print(f"Retryable error occurs for batch: {conf}, data: {data} retry: {exception}") self.retry_count += 1 + def elapsed(self) -> int: + return time.time_ns() - self.start + def main() -> None: conf = Config() @@ -40,15 +45,10 @@ def main() -> None: precision = 2 # Setting timestamp for first sensor reading + sample_window_days = 7 now = datetime.datetime.now() - now = now - datetime.timedelta(days=30) - teststart = datetime.datetime.now() - - # InfluxDB connection details - token = "" - org = "" - database = "" - url = "eu-central-1-1.aws.cloud2.influxdata.com" + now = now - datetime.timedelta(days=sample_window_days) + target_sample_count = sample_window_days * 24 * 60 * 6 callback = BatchingCallback() @@ -58,6 +58,7 @@ def main() -> None: retry_interval=5_000, max_retries=5, max_retry_delay=30_000, + max_close_wait=600_000, exponential_base=2) wco = write_client_options(success_callback=callback.success, @@ -75,8 +76,8 @@ def main() -> None: write_client_options=wco) as _client: # Creating iterator for one hour worth of data (6 sensor readings per # minute) - # for i in range(0, 525600): - for i in range(0, 52600): + print(f"Writing {target_sample_count} data points.") + for i in range(0, target_sample_count): # Adding 10 seconds to timestamp of previous sensor reading now = now + datetime.timedelta(seconds=10) # Iterating over gateways @@ -132,6 +133,8 @@ def main() -> None: print(callback.write_status_msg) print(f"Write retries: {callback.retry_count}") + print(f"Wrote {target_sample_count} data points.") + print(f"Elapsed time ms: {int(callback.elapsed() / 1_000_000)}") if __name__ == "__main__": From c6bed429f569857837f3c0bb5b1dca464272fe34 Mon Sep 17 00:00:00 2001 From: karel rehor Date: Thu, 12 Sep 2024 13:18:54 +0200 Subject: [PATCH 3/9] chore: cleanup flake8 issue --- Examples/batching_example.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Examples/batching_example.py b/Examples/batching_example.py index 247c7ea..e0ec8df 100644 --- a/Examples/batching_example.py +++ b/Examples/batching_example.py @@ -138,4 +138,4 @@ def main() -> None: if __name__ == "__main__": - main() \ No newline at end of file + main() From e5b8f7f403e53658275e33f6155bc9fb1fe6ee7f Mon Sep 17 00:00:00 2001 From: karel rehor Date: Tue, 17 Sep 2024 13:56:59 +0200 Subject: [PATCH 4/9] tests: adds integration tests of context manager on write. --- tests/test_influxdb_client_3_integration.py | 114 +++++++++++++++++++- 1 file changed, 113 insertions(+), 1 deletion(-) diff --git a/tests/test_influxdb_client_3_integration.py b/tests/test_influxdb_client_3_integration.py index d6c230f..1fb5747 100644 --- a/tests/test_influxdb_client_3_integration.py +++ b/tests/test_influxdb_client_3_integration.py @@ -1,10 +1,18 @@ +import logging import os +import random +import string import time import unittest +import pyarrow import pytest -from influxdb_client_3 import InfluxDBClient3, InfluxDBError +from influxdb_client_3 import InfluxDBClient3, InfluxDBError, write_client_options, WriteOptions + + +def random_hex(len=6): + return ''.join(random.choice(string.hexdigits) for i in range(len)) @pytest.mark.integration @@ -20,6 +28,10 @@ ) class TestInfluxDBClient3Integration(unittest.TestCase): + @pytest.fixture(autouse=True) + def inject_fixtures(self, caplog): + self._caplog = caplog + def setUp(self): self.host = os.getenv('TESTING_INFLUXDB_URL') self.token = os.getenv('TESTING_INFLUXDB_TOKEN') @@ -27,6 +39,8 @@ def setUp(self): self.client = InfluxDBClient3(host=self.host, database=self.database, token=self.token) def tearDown(self): + self._caplog.clear() + self._caplog.set_level(logging.ERROR) if self.client: self.client.close() @@ -72,3 +86,101 @@ def test_error_headers(self): self.assertIsNotNone(headers['X-Influxdb-Build']) except KeyError as ke: self.fail(f'Header {ke} not found') + + def test_batch_write_callbacks(self): + write_success = False + write_error = False + write_count = 0 + + measurement = f'test{random_hex(6)}' + data_set_size = 40 + batch_size = 10 + + def success(conf, data): + nonlocal write_success, write_count + write_success = True + write_count += 1 + + def error(conf, data, exception: InfluxDBError): + nonlocal write_error + write_error = True + + w_opts = WriteOptions( + batch_size=batch_size, + flush_interval=1_000, + jitter_interval=500 + ) + + wc_opts = write_client_options( + success_callback=success, + error_callback=error, + write_options=w_opts + ) + + now = time.time_ns() + with InfluxDBClient3(host=self.host, + database=self.database, + token=self.token, + write_client_options=wc_opts) as w_client: + + for i in range(0, data_set_size): + w_client.write(f'{measurement},location=harfa val={i}i {now - (i * 1_000_000_000)}') + + self.assertEqual(data_set_size / batch_size, write_count) + self.assertTrue(write_success) + self.assertFalse(write_error) + + with InfluxDBClient3(host=self.host, + database=self.database, + token=self.token, + write_client_options=wc_opts) as r_client: + + query = f"SELECT * FROM \"{measurement}\" WHERE time >= now() - interval '3 minute'" + reader: pyarrow.Table = r_client.query(query) + list_results = reader.to_pylist() + self.assertEqual(data_set_size, len(list_results)) + + def test_batch_write_closed(self): + + self._caplog.set_level(logging.DEBUG) + # writing measurement for last cca 3hrs + # so repeat runs in that time frame could + # result in clashed result data if always + # using same measurement name + measurement = f'test{random_hex()}' + data_size = 10_000 + w_opts = WriteOptions( + batch_size=100, + flush_interval=3_000, + jitter_interval=500 + ) + + wc_opts = write_client_options( + write_options=w_opts + ) + + now = time.time_ns() + with InfluxDBClient3(host=self.host, + database=self.database, + token=self.token, + write_client_options=wc_opts, + debug=True) as w_client: + + for i in range(0, data_size): + w_client.write(f'{measurement},location=harfa val={i}i {now - (i * 1_000_000_000)}') + + lines = self._caplog.text.splitlines() + self.assertRegex(lines[len(lines) - 1], ".*the batching processor was disposed$") + + logging.info("WRITING DONE") + with InfluxDBClient3(host=self.host, + database=self.database, + token=self.token, + write_client_options=wc_opts) as r_client: + + logging.info("PREPARING QUERY") + + query = f"SELECT * FROM \"{measurement}\" WHERE time >= now() - interval '3 hours'" + reader: pyarrow.Table = r_client.query(query, mode="") + list_results = reader.to_pylist() + self.assertEqual(data_size, len(list_results)) From d6d590a74a9d67c3f2f64c88118ef737cac25896 Mon Sep 17 00:00:00 2001 From: karel rehor Date: Wed, 18 Sep 2024 13:58:04 +0200 Subject: [PATCH 5/9] docs: update examples csv_write.py and json_write.py --- Examples/file-import/csv_write.py | 74 +++++++++++++++++++---------- Examples/file-import/json_write.py | 75 ++++++++++++++++++++---------- 2 files changed, 101 insertions(+), 48 deletions(-) diff --git a/Examples/file-import/csv_write.py b/Examples/file-import/csv_write.py index fc80c5e..da30d2e 100644 --- a/Examples/file-import/csv_write.py +++ b/Examples/file-import/csv_write.py @@ -1,10 +1,15 @@ +import logging import influxdb_client_3 as InfluxDBClient3 from influxdb_client_3 import write_client_options, WriteOptions, InfluxDBError class BatchingCallback(object): + def __init__(self): + self.write_count = 0 + def success(self, conf, data: str): + self.write_count += 1 print(f"Written batch: {conf}, data: {data}") def error(self, conf, data: str, exception: InfluxDBError): @@ -14,27 +19,48 @@ def retry(self, conf, data: str, exception: InfluxDBError): print(f"Retryable error occurs for batch: {conf}, data: {data} retry: {exception}") -callback = BatchingCallback() - -write_options = WriteOptions(batch_size=500, - flush_interval=10_000, - jitter_interval=2_000, - retry_interval=5_000, - max_retries=5, - max_retry_delay=30_000, - exponential_base=2) - -wco = write_client_options(success_callback=callback.success, - error_callback=callback.error, - retry_callback=callback.retry, - write_options=write_options - ) - -with InfluxDBClient3.InfluxDBClient3( - token="INSERT_TOKEN", - host="eu-central-1-1.aws.cloud2.influxdata.com", - org="6a841c0c08328fb1", - database="python", write_client_options=wco) as client: - client.write_file( - file='./out.csv', - timestamp_column='time', tag_columns=["provider", "machineID"]) +def main() -> None: + + # allow detailed inspection + logging.basicConfig(level=logging.DEBUG) + + callback = BatchingCallback() + + write_options = WriteOptions(batch_size=100, + flush_interval=10_000, + jitter_interval=2_000, + retry_interval=5_000, + max_retries=5, + max_retry_delay=30_000, + exponential_base=2) + + wco = write_client_options(success_callback=callback.success, + error_callback=callback.error, + retry_callback=callback.retry, + write_options=write_options + ) + + """ + token: access token generated in cloud + host: ATTN could be another AWS region or even another cloud provider + org: organization associated with account and database + database: should have retention policy 'forever' to handle older sample data timestamps + write_client_options: see above + debug: allows low-level inspection of communications and context-manager termination + """ + with (InfluxDBClient3.InfluxDBClient3( + token="INSERT_TOKEN", + host="https://us-east-1-1.aws.cloud2.influxdata.com/", + org="INSERT_ORG", + database="example_data_forever", + write_client_options=wco, + debug=True) as client): + client.write_file( + file='./out.csv', + timestamp_column='time', tag_columns=["provider", "machineID"]) + + print(f'DONE writing from csv in {callback.write_count} batch(es)') + + +if __name__ == "__main__": + main() diff --git a/Examples/file-import/json_write.py b/Examples/file-import/json_write.py index 7129e47..37e8a1c 100644 --- a/Examples/file-import/json_write.py +++ b/Examples/file-import/json_write.py @@ -1,10 +1,15 @@ +import logging import influxdb_client_3 as InfluxDBClient3 from influxdb_client_3 import write_client_options, WriteOptions, InfluxDBError class BatchingCallback(object): + def __init__(self): + self.write_count = 0 + def success(self, conf, data: str): + self.write_count += 1 print(f"Written batch: {conf}, data: {data}") def error(self, conf, data: str, exception: InfluxDBError): @@ -14,27 +19,49 @@ def retry(self, conf, data: str, exception: InfluxDBError): print(f"Retryable error occurs for batch: {conf}, data: {data} retry: {exception}") -callback = BatchingCallback() - -write_options = WriteOptions(batch_size=500, - flush_interval=10_000, - jitter_interval=2_000, - retry_interval=5_000, - max_retries=5, - max_retry_delay=30_000, - exponential_base=2) - -wco = write_client_options(success_callback=callback.success, - error_callback=callback.error, - retry_callback=callback.retry, - write_options=write_options - ) - -with InfluxDBClient3.InfluxDBClient3( - token="INSERT_TOKEN", - host="eu-central-1-1.aws.cloud2.influxdata.com", - org="6a841c0c08328fb1", - database="python", write_client_options=wco) as client: - client.write_file( - file='./out.json', - timestamp_column='time', tag_columns=["provider", "machineID"], date_unit='ns') +def main() -> None: + + # allow detailed inspection + logging.basicConfig(level=logging.DEBUG) + + callback = BatchingCallback() + + write_options = WriteOptions(batch_size=100, + flush_interval=10_000, + jitter_interval=2_000, + retry_interval=5_000, + max_retries=5, + max_retry_delay=30_000, + exponential_base=2) + + wco = write_client_options(success_callback=callback.success, + error_callback=callback.error, + retry_callback=callback.retry, + write_options=write_options + ) + """ + token: access token generated in cloud + host: ATTN could be another AWS region or even another cloud provider + org: organization associated with account and database + database: should have retention policy 'forever' to handle older sample data timestamps + write_client_options: see above + debug: allows low-level inspection of communications and context-manager termination + """ + with InfluxDBClient3.InfluxDBClient3( + token="INSERT_TOKEN", + host="https://us-east-1-1.aws.cloud2.influxdata.com/", + org="INSERT_ORG", + database="example_data_forever", + write_client_options=wco, + debug=True) as client: + client.write_file( + file='./out.json', + timestamp_column='time', + tag_columns=["provider", "machineID"], + date_unit='ns') + + print(f"DONE writing from json in {callback.write_count} batch(es)") + + +if __name__ == "__main__": + main() From 73f369e7fd441a230ec4537a407091969f05d396 Mon Sep 17 00:00:00 2001 From: karel rehor Date: Wed, 18 Sep 2024 14:30:05 +0200 Subject: [PATCH 6/9] chore: fix context manager block --- Examples/file-import/csv_write.py | 4 ++-- Examples/file-import/{out.csv => out_orig.csv} | 0 Examples/file-import/{out.json => out_orig.json} | 0 3 files changed, 2 insertions(+), 2 deletions(-) rename Examples/file-import/{out.csv => out_orig.csv} (100%) rename Examples/file-import/{out.json => out_orig.json} (100%) diff --git a/Examples/file-import/csv_write.py b/Examples/file-import/csv_write.py index da30d2e..2c6ed44 100644 --- a/Examples/file-import/csv_write.py +++ b/Examples/file-import/csv_write.py @@ -48,13 +48,13 @@ def main() -> None: write_client_options: see above debug: allows low-level inspection of communications and context-manager termination """ - with (InfluxDBClient3.InfluxDBClient3( + with InfluxDBClient3.InfluxDBClient3( token="INSERT_TOKEN", host="https://us-east-1-1.aws.cloud2.influxdata.com/", org="INSERT_ORG", database="example_data_forever", write_client_options=wco, - debug=True) as client): + debug=True) as client: client.write_file( file='./out.csv', timestamp_column='time', tag_columns=["provider", "machineID"]) diff --git a/Examples/file-import/out.csv b/Examples/file-import/out_orig.csv similarity index 100% rename from Examples/file-import/out.csv rename to Examples/file-import/out_orig.csv diff --git a/Examples/file-import/out.json b/Examples/file-import/out_orig.json similarity index 100% rename from Examples/file-import/out.json rename to Examples/file-import/out_orig.json From cb15646bb1a6d46395c9ec3926ffd6bdb70a7fae Mon Sep 17 00:00:00 2001 From: karel rehor Date: Wed, 18 Sep 2024 14:31:12 +0200 Subject: [PATCH 7/9] chore: fix schema conflict between example data files. --- Examples/file-import/out.csv | 163 ++++++++++++++++++++++++++++++++++ Examples/file-import/out.json | 1 + 2 files changed, 164 insertions(+) create mode 100644 Examples/file-import/out.csv create mode 100644 Examples/file-import/out.json diff --git a/Examples/file-import/out.csv b/Examples/file-import/out.csv new file mode 100644 index 0000000..881baf5 --- /dev/null +++ b/Examples/file-import/out.csv @@ -0,0 +1,163 @@ +iox::measurement,time,host,load,machineID,power,provider,temperature,topic,vibration +machine_data_csv,2023-06-02 16:42:42.317550714,491cc20bbe13,120.0,machine3,301.0,Smith Group,80.0,machine/machine3,310 +machine_data_csv,2023-06-02 16:42:42.317757560,491cc20bbe13,23.0,machine1,183.0,"Morales, Robinson and Newman",31.0,machine/machine1,78 +machine_data_csv,2023-06-02 16:42:42.317787898,491cc20bbe13,13.0,machine2,198.0,Thomas and Sons,34.0,machine/machine2,73 +machine_data_csv,2023-06-02 16:42:43.318452979,491cc20bbe13,120.0,machine3,307.0,Smith Group,81.0,machine/machine3,332 +machine_data_csv,2023-06-02 16:42:43.318733897,491cc20bbe13,23.0,machine1,191.0,"Morales, Robinson and Newman",30.0,machine/machine1,53 +machine_data_csv,2023-06-02 16:42:43.318895072,491cc20bbe13,13.0,machine2,197.0,Thomas and Sons,31.0,machine/machine2,56 +machine_data_csv,2023-06-02 16:42:44.319014820,491cc20bbe13,120.0,machine3,302.0,Smith Group,87.0,machine/machine3,406 +machine_data_csv,2023-06-02 16:42:44.319289702,491cc20bbe13,23.0,machine1,194.0,"Morales, Robinson and Newman",31.0,machine/machine1,65 +machine_data_csv,2023-06-02 16:42:44.319743319,491cc20bbe13,13.0,machine2,192.0,Thomas and Sons,34.0,machine/machine2,64 +machine_data_csv,2023-06-02 16:42:45.319492285,491cc20bbe13,120.0,machine3,312.0,Smith Group,83.0,machine/machine3,460 +machine_data_csv,2023-06-02 16:42:45.319953921,491cc20bbe13,23.0,machine1,199.0,"Morales, Robinson and Newman",29.0,machine/machine1,69 +machine_data_csv,2023-06-02 16:42:45.319985284,491cc20bbe13,13.0,machine2,188.0,Thomas and Sons,29.0,machine/machine2,72 +machine_data_csv,2023-06-02 16:42:46.319917712,491cc20bbe13,120.0,machine3,317.0,Smith Group,90.0,machine/machine3,363 +machine_data_csv,2023-06-02 16:42:46.320373453,491cc20bbe13,23.0,machine1,183.0,"Morales, Robinson and Newman",34.0,machine/machine1,69 +machine_data_csv,2023-06-02 16:42:46.320760737,491cc20bbe13,13.0,machine2,184.0,Thomas and Sons,31.0,machine/machine2,78 +machine_data_csv,2023-06-02 16:42:47.320548979,491cc20bbe13,120.0,machine3,303.0,Smith Group,80.0,machine/machine3,419 +machine_data_csv,2023-06-02 16:42:47.320966397,491cc20bbe13,23.0,machine1,181.0,"Morales, Robinson and Newman",30.0,machine/machine1,71 +machine_data_csv,2023-06-02 16:42:47.321006298,491cc20bbe13,13.0,machine2,186.0,Thomas and Sons,31.0,machine/machine2,60 +machine_data_csv,2023-06-02 16:42:48.321265346,491cc20bbe13,120.0,machine3,305.0,Smith Group,89.0,machine/machine3,367 +machine_data_csv,2023-06-02 16:42:48.321382477,491cc20bbe13,23.0,machine1,197.0,"Morales, Robinson and Newman",33.0,machine/machine1,54 +machine_data_csv,2023-06-02 16:42:48.321535645,491cc20bbe13,13.0,machine2,195.0,Thomas and Sons,30.0,machine/machine2,68 +machine_data_csv,2023-06-02 16:42:49.321847629,491cc20bbe13,120.0,machine3,317.0,Smith Group,86.0,machine/machine3,334 +machine_data_csv,2023-06-02 16:42:49.322119417,491cc20bbe13,13.0,machine2,188.0,Thomas and Sons,29.0,machine/machine2,71 +machine_data_csv,2023-06-02 16:42:49.322147172,491cc20bbe13,23.0,machine1,184.0,"Morales, Robinson and Newman",34.0,machine/machine1,71 +machine_data_csv,2023-06-02 16:42:50.322698923,491cc20bbe13,120.0,machine3,302.0,Smith Group,87.0,machine/machine3,407 +machine_data_csv,2023-06-02 16:42:50.323173071,491cc20bbe13,23.0,machine1,193.0,"Morales, Robinson and Newman",32.0,machine/machine1,59 +machine_data_csv,2023-06-02 16:42:50.323237285,491cc20bbe13,13.0,machine2,182.0,Thomas and Sons,30.0,machine/machine2,72 +machine_data_csv,2023-06-02 16:42:51.323193568,491cc20bbe13,120.0,machine3,303.0,Smith Group,90.0,machine/machine3,343 +machine_data_csv,2023-06-02 16:42:51.323662012,491cc20bbe13,13.0,machine2,188.0,Thomas and Sons,31.0,machine/machine2,67 +machine_data_csv,2023-06-02 16:42:51.323725850,491cc20bbe13,23.0,machine1,187.0,"Morales, Robinson and Newman",30.0,machine/machine1,69 +machine_data_csv,2023-06-02 16:42:52.323837298,491cc20bbe13,120.0,machine3,319.0,Smith Group,89.0,machine/machine3,406 +machine_data_csv,2023-06-02 16:42:52.324179952,491cc20bbe13,23.0,machine1,192.0,"Morales, Robinson and Newman",31.0,machine/machine1,65 +machine_data_csv,2023-06-02 16:42:52.324204211,491cc20bbe13,13.0,machine2,193.0,Thomas and Sons,34.0,machine/machine2,61 +machine_data_csv,2023-06-02 16:42:53.324457761,491cc20bbe13,120.0,machine3,306.0,Smith Group,81.0,machine/machine3,432 +machine_data_csv,2023-06-02 16:42:53.324791324,491cc20bbe13,23.0,machine1,196.0,"Morales, Robinson and Newman",30.0,machine/machine1,59 +machine_data_csv,2023-06-02 16:42:53.324822237,491cc20bbe13,13.0,machine2,184.0,Thomas and Sons,30.0,machine/machine2,62 +machine_data_csv,2023-06-02 16:42:54.324940162,491cc20bbe13,120.0,machine3,319.0,Smith Group,87.0,machine/machine3,473 +machine_data_csv,2023-06-02 16:42:54.325470257,491cc20bbe13,23.0,machine1,183.0,"Morales, Robinson and Newman",29.0,machine/machine1,69 +machine_data_csv,2023-06-02 16:42:54.325535111,491cc20bbe13,13.0,machine2,184.0,Thomas and Sons,34.0,machine/machine2,72 +machine_data_csv,2023-06-02 16:42:55.325452588,491cc20bbe13,120.0,machine3,308.0,Smith Group,88.0,machine/machine3,478 +machine_data_csv,2023-06-02 16:42:55.326241988,491cc20bbe13,23.0,machine1,180.0,"Morales, Robinson and Newman",32.0,machine/machine1,67 +machine_data_csv,2023-06-02 16:42:55.326458954,491cc20bbe13,13.0,machine2,181.0,Thomas and Sons,34.0,machine/machine2,53 +machine_data_csv,2023-06-02 16:42:56.325962575,491cc20bbe13,120.0,machine3,301.0,Smith Group,89.0,machine/machine3,366 +machine_data_csv,2023-06-02 16:42:56.326547488,491cc20bbe13,23.0,machine1,194.0,"Morales, Robinson and Newman",33.0,machine/machine1,77 +machine_data_csv,2023-06-02 16:42:56.326817078,491cc20bbe13,13.0,machine2,182.0,Thomas and Sons,33.0,machine/machine2,54 +machine_data_csv,2023-06-02 16:42:57.326651847,491cc20bbe13,120.0,machine3,316.0,Smith Group,82.0,machine/machine3,446 +machine_data_csv,2023-06-02 16:42:57.326903277,491cc20bbe13,23.0,machine1,186.0,"Morales, Robinson and Newman",32.0,machine/machine1,57 +machine_data_csv,2023-06-02 16:42:57.327169455,491cc20bbe13,13.0,machine2,183.0,Thomas and Sons,33.0,machine/machine2,50 +machine_data_csv,2023-06-02 16:42:58.327381372,491cc20bbe13,120.0,machine3,303.0,Smith Group,83.0,machine/machine3,329 +machine_data_csv,2023-06-02 16:42:58.327785814,491cc20bbe13,13.0,machine2,189.0,Thomas and Sons,31.0,machine/machine2,54 +machine_data_csv,2023-06-02 16:42:58.328075202,491cc20bbe13,23.0,machine1,184.0,"Morales, Robinson and Newman",34.0,machine/machine1,67 +machine_data_csv,2023-06-02 16:42:59.328107312,491cc20bbe13,120.0,machine3,300.0,Smith Group,90.0,machine/machine3,446 +machine_data_csv,2023-06-02 16:42:59.328697178,491cc20bbe13,13.0,machine2,196.0,Thomas and Sons,32.0,machine/machine2,51 +machine_data_csv,2023-06-02 16:42:59.328842456,491cc20bbe13,23.0,machine1,183.0,"Morales, Robinson and Newman",30.0,machine/machine1,56 +machine_data_csv,2023-06-02 16:43:00.328689987,491cc20bbe13,120.0,machine3,300.0,Smith Group,81.0,machine/machine3,460 +machine_data_csv,2023-06-02 16:43:00.328730602,491cc20bbe13,13.0,machine2,180.0,Thomas and Sons,34.0,machine/machine2,57 +machine_data_csv,2023-06-02 16:43:00.329187607,491cc20bbe13,23.0,machine1,187.0,"Morales, Robinson and Newman",33.0,machine/machine1,70 +machine_data_csv,2023-06-02 16:43:01.329623051,491cc20bbe13,13.0,machine2,194.0,Thomas and Sons,33.0,machine/machine2,79 +machine_data_csv,2023-06-02 16:43:01.329737661,491cc20bbe13,120.0,machine3,314.0,Smith Group,85.0,machine/machine3,441 +machine_data_csv,2023-06-02 16:43:01.329994500,491cc20bbe13,23.0,machine1,196.0,"Morales, Robinson and Newman",34.0,machine/machine1,70 +machine_data_csv,2023-06-02 16:43:02.330561375,491cc20bbe13,13.0,machine2,182.0,Thomas and Sons,31.0,machine/machine2,66 +machine_data_csv,2023-06-02 16:43:02.330611344,491cc20bbe13,120.0,machine3,304.0,Smith Group,89.0,machine/machine3,455 +machine_data_csv,2023-06-02 16:43:02.330943808,491cc20bbe13,23.0,machine1,186.0,"Morales, Robinson and Newman",29.0,machine/machine1,77 +machine_data_csv,2023-06-02 16:43:03.331222016,491cc20bbe13,120.0,machine3,319.0,Smith Group,90.0,machine/machine3,459 +machine_data_csv,2023-06-02 16:43:03.331373671,491cc20bbe13,23.0,machine1,196.0,"Morales, Robinson and Newman",29.0,machine/machine1,60 +machine_data_csv,2023-06-02 16:43:03.331578703,491cc20bbe13,13.0,machine2,195.0,Thomas and Sons,34.0,machine/machine2,60 +machine_data_csv,2023-06-02 16:43:04.331723999,491cc20bbe13,120.0,machine3,311.0,Smith Group,80.0,machine/machine3,493 +machine_data_csv,2023-06-02 16:43:04.332158179,491cc20bbe13,23.0,machine1,198.0,"Morales, Robinson and Newman",31.0,machine/machine1,71 +machine_data_csv,2023-06-02 16:43:04.332222502,491cc20bbe13,13.0,machine2,188.0,Thomas and Sons,34.0,machine/machine2,72 +machine_data_csv,2023-06-02 16:43:05.332522723,491cc20bbe13,120.0,machine3,305.0,Smith Group,89.0,machine/machine3,442 +machine_data_csv,2023-06-02 16:43:05.332606103,491cc20bbe13,23.0,machine1,189.0,"Morales, Robinson and Newman",33.0,machine/machine1,71 +machine_data_csv,2023-06-02 16:43:05.332956871,491cc20bbe13,13.0,machine2,191.0,Thomas and Sons,34.0,machine/machine2,76 +machine_data_csv,2023-06-02 16:43:06.332934234,491cc20bbe13,120.0,machine3,313.0,Smith Group,87.0,machine/machine3,470 +machine_data_csv,2023-06-02 16:43:06.333179737,491cc20bbe13,13.0,machine2,193.0,Thomas and Sons,29.0,machine/machine2,74 +machine_data_csv,2023-06-02 16:43:06.333464546,491cc20bbe13,23.0,machine1,193.0,"Morales, Robinson and Newman",31.0,machine/machine1,61 +machine_data_csv,2023-06-02 16:43:07.333538813,491cc20bbe13,120.0,machine3,303.0,Smith Group,86.0,machine/machine3,443 +machine_data_csv,2023-06-02 16:43:07.333592979,491cc20bbe13,13.0,machine2,197.0,Thomas and Sons,33.0,machine/machine2,62 +machine_data_csv,2023-06-02 16:43:07.333964542,491cc20bbe13,23.0,machine1,197.0,"Morales, Robinson and Newman",29.0,machine/machine1,70 +machine_data_csv,2023-06-02 16:43:08.333966919,491cc20bbe13,120.0,machine3,308.0,Smith Group,84.0,machine/machine3,330 +machine_data_csv,2023-06-02 16:43:08.334168052,491cc20bbe13,13.0,machine2,195.0,Thomas and Sons,31.0,machine/machine2,73 +machine_data_csv,2023-06-02 16:43:08.334236775,491cc20bbe13,23.0,machine1,184.0,"Morales, Robinson and Newman",30.0,machine/machine1,73 +machine_data_csv,2023-06-02 16:43:09.334998961,491cc20bbe13,120.0,machine3,303.0,Smith Group,88.0,machine/machine3,395 +machine_data_csv,2023-06-02 16:43:09.335091622,491cc20bbe13,21.0,machine2,193.0,Thomas and Sons,34.0,machine/machine2,72 +machine_data_csv,2023-06-02 16:43:09.335117396,491cc20bbe13,51.0,machine1,201.0,"Morales, Robinson and Newman",37.0,machine/machine1,90 +machine_data_csv,2023-06-02 16:43:10.335359448,491cc20bbe13,53.0,machine3,209.0,Smith Group,36.0,machine/machine3,89 +machine_data_csv,2023-06-02 16:43:10.335917983,491cc20bbe13,21.0,machine2,189.0,Thomas and Sons,32.0,machine/machine2,58 +machine_data_csv,2023-06-02 16:43:10.335961039,491cc20bbe13,51.0,machine1,203.0,"Morales, Robinson and Newman",38.0,machine/machine1,85 +machine_data_csv,2023-06-02 16:43:11.335865097,491cc20bbe13,53.0,machine3,211.0,Smith Group,39.0,machine/machine3,83 +machine_data_csv,2023-06-02 16:43:11.336300844,491cc20bbe13,21.0,machine2,194.0,Thomas and Sons,29.0,machine/machine2,58 +machine_data_csv,2023-06-02 16:43:11.336354602,491cc20bbe13,51.0,machine1,205.0,"Morales, Robinson and Newman",38.0,machine/machine1,85 +machine_data_csv,2023-06-02 16:43:12.336856584,491cc20bbe13,53.0,machine3,213.0,Smith Group,37.0,machine/machine3,88 +machine_data_csv,2023-06-02 16:43:12.337596930,491cc20bbe13,21.0,machine2,193.0,Thomas and Sons,32.0,machine/machine2,55 +machine_data_csv,2023-06-02 16:43:12.337627620,491cc20bbe13,51.0,machine1,203.0,"Morales, Robinson and Newman",36.0,machine/machine1,81 +machine_data_csv,2023-06-02 16:43:13.337427240,491cc20bbe13,53.0,machine3,206.0,Smith Group,38.0,machine/machine3,80 +machine_data_csv,2023-06-02 16:43:13.337811242,491cc20bbe13,21.0,machine2,184.0,Thomas and Sons,32.0,machine/machine2,73 +machine_data_csv,2023-06-02 16:43:13.337874112,491cc20bbe13,51.0,machine1,201.0,"Morales, Robinson and Newman",40.0,machine/machine1,81 +machine_data_csv,2023-06-02 16:43:14.337992849,491cc20bbe13,53.0,machine3,217.0,Smith Group,39.0,machine/machine3,89 +machine_data_csv,2023-06-02 16:43:14.338326166,491cc20bbe13,21.0,machine2,198.0,Thomas and Sons,34.0,machine/machine2,63 +machine_data_csv,2023-06-02 16:43:14.338634931,491cc20bbe13,51.0,machine1,205.0,"Morales, Robinson and Newman",37.0,machine/machine1,81 +machine_data_csv,2023-06-02 16:43:15.339009274,491cc20bbe13,53.0,machine3,210.0,Smith Group,40.0,machine/machine3,80 +machine_data_csv,2023-06-02 16:43:15.339100441,491cc20bbe13,51.0,machine1,206.0,"Morales, Robinson and Newman",38.0,machine/machine1,90 +machine_data_csv,2023-06-02 16:43:15.339762188,491cc20bbe13,21.0,machine2,188.0,Thomas and Sons,30.0,machine/machine2,55 +machine_data_csv,2023-06-02 16:43:16.340230361,491cc20bbe13,51.0,machine1,201.0,"Morales, Robinson and Newman",38.0,machine/machine1,84 +machine_data_csv,2023-06-02 16:43:16.340650516,491cc20bbe13,21.0,machine2,184.0,Thomas and Sons,33.0,machine/machine2,64 +machine_data_csv,2023-06-02 16:43:16.340991256,491cc20bbe13,53.0,machine3,203.0,Smith Group,37.0,machine/machine3,84 +machine_data_csv,2023-06-02 16:43:17.341908770,491cc20bbe13,53.0,machine3,211.0,Smith Group,40.0,machine/machine3,84 +machine_data_csv,2023-06-02 16:43:17.342360815,491cc20bbe13,51.0,machine1,215.0,"Morales, Robinson and Newman",38.0,machine/machine1,86 +machine_data_csv,2023-06-02 16:43:17.342426363,491cc20bbe13,21.0,machine2,194.0,Thomas and Sons,33.0,machine/machine2,62 +machine_data_csv,2023-06-02 16:43:18.342445484,491cc20bbe13,53.0,machine3,201.0,Smith Group,36.0,machine/machine3,90 +machine_data_csv,2023-06-02 16:43:18.342768157,491cc20bbe13,21.0,machine2,197.0,Thomas and Sons,30.0,machine/machine2,53 +machine_data_csv,2023-06-02 16:43:18.342799655,491cc20bbe13,51.0,machine1,211.0,"Morales, Robinson and Newman",36.0,machine/machine1,87 +machine_data_csv,2023-06-02 16:43:19.342914561,491cc20bbe13,53.0,machine3,206.0,Smith Group,40.0,machine/machine3,80 +machine_data_csv,2023-06-02 16:43:19.343415645,491cc20bbe13,21.0,machine2,196.0,Thomas and Sons,33.0,machine/machine2,53 +machine_data_csv,2023-06-02 16:43:19.343478737,491cc20bbe13,51.0,machine1,220.0,"Morales, Robinson and Newman",36.0,machine/machine1,89 +machine_data_csv,2023-06-02 16:43:20.343479811,491cc20bbe13,53.0,machine3,216.0,Smith Group,36.0,machine/machine3,84 +machine_data_csv,2023-06-02 16:43:20.344124763,491cc20bbe13,21.0,machine2,193.0,Thomas and Sons,32.0,machine/machine2,77 +machine_data_csv,2023-06-02 16:43:20.344153596,491cc20bbe13,51.0,machine1,200.0,"Morales, Robinson and Newman",35.0,machine/machine1,89 +machine_data_csv,2023-06-02 16:43:21.343964197,491cc20bbe13,53.0,machine3,212.0,Smith Group,35.0,machine/machine3,86 +machine_data_csv,2023-06-02 16:43:21.344617756,491cc20bbe13,21.0,machine2,183.0,Thomas and Sons,33.0,machine/machine2,64 +machine_data_csv,2023-06-02 16:43:21.344685120,491cc20bbe13,51.0,machine1,209.0,"Morales, Robinson and Newman",35.0,machine/machine1,86 +machine_data_csv,2023-06-02 16:43:22.344825564,491cc20bbe13,53.0,machine3,205.0,Smith Group,39.0,machine/machine3,87 +machine_data_csv,2023-06-02 16:43:22.345135145,491cc20bbe13,21.0,machine2,184.0,Thomas and Sons,31.0,machine/machine2,60 +machine_data_csv,2023-06-02 16:43:22.345167055,491cc20bbe13,51.0,machine1,220.0,"Morales, Robinson and Newman",38.0,machine/machine1,81 +machine_data_csv,2023-06-02 16:43:23.345437181,491cc20bbe13,53.0,machine3,200.0,Smith Group,37.0,machine/machine3,86 +machine_data_csv,2023-06-02 16:43:23.345506574,491cc20bbe13,51.0,machine1,214.0,"Morales, Robinson and Newman",37.0,machine/machine1,86 +machine_data_csv,2023-06-02 16:43:23.345564703,491cc20bbe13,21.0,machine2,193.0,Thomas and Sons,33.0,machine/machine2,62 +machine_data_csv,2023-06-02 16:43:24.346349521,491cc20bbe13,53.0,machine3,210.0,Smith Group,37.0,machine/machine3,85 +machine_data_csv,2023-06-02 16:43:24.346383833,491cc20bbe13,51.0,machine1,211.0,"Morales, Robinson and Newman",37.0,machine/machine1,87 +machine_data_csv,2023-06-02 16:43:24.346401291,491cc20bbe13,21.0,machine2,193.0,Thomas and Sons,32.0,machine/machine2,54 +machine_data_csv,2023-06-02 16:43:25.346821289,491cc20bbe13,53.0,machine3,220.0,Smith Group,37.0,machine/machine3,89 +machine_data_csv,2023-06-02 16:43:25.346921797,491cc20bbe13,21.0,machine2,190.0,Thomas and Sons,34.0,machine/machine2,75 +machine_data_csv,2023-06-02 16:43:25.347491870,491cc20bbe13,51.0,machine1,214.0,"Morales, Robinson and Newman",39.0,machine/machine1,83 +machine_data_csv,2023-06-02 16:43:26.347838431,491cc20bbe13,21.0,machine2,186.0,Thomas and Sons,29.0,machine/machine2,79 +machine_data_csv,2023-06-02 16:43:26.348427616,491cc20bbe13,51.0,machine1,200.0,"Morales, Robinson and Newman",40.0,machine/machine1,85 +machine_data_csv,2023-06-02 16:43:26.348455741,491cc20bbe13,53.0,machine3,205.0,Smith Group,40.0,machine/machine3,80 +machine_data_csv,2023-06-02 16:43:27.348535696,491cc20bbe13,21.0,machine2,189.0,Thomas and Sons,34.0,machine/machine2,79 +machine_data_csv,2023-06-02 16:43:27.349173287,491cc20bbe13,51.0,machine1,215.0,"Morales, Robinson and Newman",36.0,machine/machine1,86 +machine_data_csv,2023-06-02 16:43:27.349217288,491cc20bbe13,53.0,machine3,213.0,Smith Group,39.0,machine/machine3,83 +machine_data_csv,2023-06-02 16:43:28.348964054,491cc20bbe13,21.0,machine2,191.0,Thomas and Sons,31.0,machine/machine2,63 +machine_data_csv,2023-06-02 16:43:28.349958403,491cc20bbe13,51.0,machine1,211.0,"Morales, Robinson and Newman",35.0,machine/machine1,84 +machine_data_csv,2023-06-02 16:43:28.350213700,491cc20bbe13,53.0,machine3,201.0,Smith Group,38.0,machine/machine3,81 +machine_data_csv,2023-06-02 16:43:29.349501656,491cc20bbe13,21.0,machine2,190.0,Thomas and Sons,30.0,machine/machine2,70 +machine_data_csv,2023-06-02 16:43:29.350320992,491cc20bbe13,51.0,machine1,209.0,"Morales, Robinson and Newman",35.0,machine/machine1,88 +machine_data_csv,2023-06-02 16:43:29.350858026,491cc20bbe13,53.0,machine3,204.0,Smith Group,36.0,machine/machine3,82 +machine_data_csv,2023-06-02 16:43:30.350640276,491cc20bbe13,21.0,machine2,197.0,Thomas and Sons,30.0,machine/machine2,55 +machine_data_csv,2023-06-02 16:43:30.351158057,491cc20bbe13,51.0,machine1,214.0,"Morales, Robinson and Newman",36.0,machine/machine1,90 +machine_data_csv,2023-06-02 16:43:30.351331667,491cc20bbe13,53.0,machine3,210.0,Smith Group,39.0,machine/machine3,85 +machine_data_csv,2023-06-02 16:43:31.351859842,491cc20bbe13,21.0,machine2,188.0,Thomas and Sons,29.0,machine/machine2,65 +machine_data_csv,2023-06-02 16:43:31.352098083,491cc20bbe13,51.0,machine1,214.0,"Morales, Robinson and Newman",35.0,machine/machine1,86 +machine_data_csv,2023-06-02 16:43:31.352141060,491cc20bbe13,53.0,machine3,213.0,Smith Group,37.0,machine/machine3,84 +machine_data_csv,2023-06-02 16:43:32.352201239,491cc20bbe13,21.0,machine2,195.0,Thomas and Sons,32.0,machine/machine2,56 +machine_data_csv,2023-06-02 16:43:32.352517261,491cc20bbe13,51.0,machine1,205.0,"Morales, Robinson and Newman",37.0,machine/machine1,84 +machine_data_csv,2023-06-02 16:43:32.352589820,491cc20bbe13,53.0,machine3,215.0,Smith Group,36.0,machine/machine3,85 +machine_data_csv,2023-06-02 16:43:33.352642145,491cc20bbe13,21.0,machine2,187.0,Thomas and Sons,34.0,machine/machine2,68 +machine_data_csv,2023-06-02 16:43:33.353162708,491cc20bbe13,51.0,machine1,218.0,"Morales, Robinson and Newman",35.0,machine/machine1,82 +machine_data_csv,2023-06-02 16:43:33.353192522,491cc20bbe13,53.0,machine3,205.0,Smith Group,36.0,machine/machine3,89 +machine_data_csv,2023-06-02 16:43:34.353255548,491cc20bbe13,21.0,machine2,197.0,Thomas and Sons,31.0,machine/machine2,50 +machine_data_csv,2023-06-02 16:43:34.353521359,491cc20bbe13,51.0,machine1,205.0,"Morales, Robinson and Newman",38.0,machine/machine1,80 +machine_data_csv,2023-06-02 16:43:34.353592745,491cc20bbe13,53.0,machine3,202.0,Smith Group,38.0,machine/machine3,83 +machine_data_csv,2023-06-02 16:43:35.353829588,491cc20bbe13,21.0,machine2,186.0,Thomas and Sons,30.0,machine/machine2,68 +machine_data_csv,2023-06-02 16:43:35.354477346,491cc20bbe13,53.0,machine3,215.0,Smith Group,36.0,machine/machine3,84 +machine_data_csv,2023-06-02 16:43:35.354644118,491cc20bbe13,51.0,machine1,206.0,"Morales, Robinson and Newman",38.0,machine/machine1,85 diff --git a/Examples/file-import/out.json b/Examples/file-import/out.json new file mode 100644 index 0000000..9d3a175 --- /dev/null +++ b/Examples/file-import/out.json @@ -0,0 +1 @@ +[{"iox::measurement":"machine_data_json","time":1685724162317550714,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":301.0,"provider":"Smith Group","temperature":80.0,"topic":"machine\/machine3","vibration":310.0},{"iox::measurement":"machine_data_json","time":1685724162317757560,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":183.0,"provider":"Morales, Robinson and Newman","temperature":31.0,"topic":"machine\/machine1","vibration":78.0},{"iox::measurement":"machine_data_json","time":1685724162317787898,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":198.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":73.0},{"iox::measurement":"machine_data_json","time":1685724163318452979,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":307.0,"provider":"Smith Group","temperature":81.0,"topic":"machine\/machine3","vibration":332.0},{"iox::measurement":"machine_data_json","time":1685724163318733897,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":191.0,"provider":"Morales, Robinson and Newman","temperature":30.0,"topic":"machine\/machine1","vibration":53.0},{"iox::measurement":"machine_data_json","time":1685724163318895072,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":197.0,"provider":"Thomas and Sons","temperature":31.0,"topic":"machine\/machine2","vibration":56.0},{"iox::measurement":"machine_data_json","time":1685724164319014820,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":302.0,"provider":"Smith Group","temperature":87.0,"topic":"machine\/machine3","vibration":406.0},{"iox::measurement":"machine_data_json","time":1685724164319289702,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":194.0,"provider":"Morales, Robinson and Newman","temperature":31.0,"topic":"machine\/machine1","vibration":65.0},{"iox::measurement":"machine_data_json","time":1685724164319743319,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":192.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":64.0},{"iox::measurement":"machine_data_json","time":1685724165319492285,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":312.0,"provider":"Smith Group","temperature":83.0,"topic":"machine\/machine3","vibration":460.0},{"iox::measurement":"machine_data_json","time":1685724165319953921,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":199.0,"provider":"Morales, Robinson and Newman","temperature":29.0,"topic":"machine\/machine1","vibration":69.0},{"iox::measurement":"machine_data_json","time":1685724165319985284,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":188.0,"provider":"Thomas and Sons","temperature":29.0,"topic":"machine\/machine2","vibration":72.0},{"iox::measurement":"machine_data_json","time":1685724166319917712,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":317.0,"provider":"Smith Group","temperature":90.0,"topic":"machine\/machine3","vibration":363.0},{"iox::measurement":"machine_data_json","time":1685724166320373453,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":183.0,"provider":"Morales, Robinson and Newman","temperature":34.0,"topic":"machine\/machine1","vibration":69.0},{"iox::measurement":"machine_data_json","time":1685724166320760737,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":184.0,"provider":"Thomas and Sons","temperature":31.0,"topic":"machine\/machine2","vibration":78.0},{"iox::measurement":"machine_data_json","time":1685724167320548979,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":303.0,"provider":"Smith Group","temperature":80.0,"topic":"machine\/machine3","vibration":419.0},{"iox::measurement":"machine_data_json","time":1685724167320966397,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":181.0,"provider":"Morales, Robinson and Newman","temperature":30.0,"topic":"machine\/machine1","vibration":71.0},{"iox::measurement":"machine_data_json","time":1685724167321006298,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":186.0,"provider":"Thomas and Sons","temperature":31.0,"topic":"machine\/machine2","vibration":60.0},{"iox::measurement":"machine_data_json","time":1685724168321265346,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":305.0,"provider":"Smith Group","temperature":89.0,"topic":"machine\/machine3","vibration":367.0},{"iox::measurement":"machine_data_json","time":1685724168321382477,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":197.0,"provider":"Morales, Robinson and Newman","temperature":33.0,"topic":"machine\/machine1","vibration":54.0},{"iox::measurement":"machine_data_json","time":1685724168321535645,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":195.0,"provider":"Thomas and Sons","temperature":30.0,"topic":"machine\/machine2","vibration":68.0},{"iox::measurement":"machine_data_json","time":1685724169321847629,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":317.0,"provider":"Smith Group","temperature":86.0,"topic":"machine\/machine3","vibration":334.0},{"iox::measurement":"machine_data_json","time":1685724169322119417,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":188.0,"provider":"Thomas and Sons","temperature":29.0,"topic":"machine\/machine2","vibration":71.0},{"iox::measurement":"machine_data_json","time":1685724169322147172,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":184.0,"provider":"Morales, Robinson and Newman","temperature":34.0,"topic":"machine\/machine1","vibration":71.0},{"iox::measurement":"machine_data_json","time":1685724170322698923,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":302.0,"provider":"Smith Group","temperature":87.0,"topic":"machine\/machine3","vibration":407.0},{"iox::measurement":"machine_data_json","time":1685724170323173071,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":193.0,"provider":"Morales, Robinson and Newman","temperature":32.0,"topic":"machine\/machine1","vibration":59.0},{"iox::measurement":"machine_data_json","time":1685724170323237285,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":182.0,"provider":"Thomas and Sons","temperature":30.0,"topic":"machine\/machine2","vibration":72.0},{"iox::measurement":"machine_data_json","time":1685724171323193568,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":303.0,"provider":"Smith Group","temperature":90.0,"topic":"machine\/machine3","vibration":343.0},{"iox::measurement":"machine_data_json","time":1685724171323662012,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":188.0,"provider":"Thomas and Sons","temperature":31.0,"topic":"machine\/machine2","vibration":67.0},{"iox::measurement":"machine_data_json","time":1685724171323725850,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":187.0,"provider":"Morales, Robinson and Newman","temperature":30.0,"topic":"machine\/machine1","vibration":69.0},{"iox::measurement":"machine_data_json","time":1685724172323837298,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":319.0,"provider":"Smith Group","temperature":89.0,"topic":"machine\/machine3","vibration":406.0},{"iox::measurement":"machine_data_json","time":1685724172324179952,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":192.0,"provider":"Morales, Robinson and Newman","temperature":31.0,"topic":"machine\/machine1","vibration":65.0},{"iox::measurement":"machine_data_json","time":1685724172324204211,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":193.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":61.0},{"iox::measurement":"machine_data_json","time":1685724173324457761,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":306.0,"provider":"Smith Group","temperature":81.0,"topic":"machine\/machine3","vibration":432.0},{"iox::measurement":"machine_data_json","time":1685724173324791324,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":196.0,"provider":"Morales, Robinson and Newman","temperature":30.0,"topic":"machine\/machine1","vibration":59.0},{"iox::measurement":"machine_data_json","time":1685724173324822237,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":184.0,"provider":"Thomas and Sons","temperature":30.0,"topic":"machine\/machine2","vibration":62.0},{"iox::measurement":"machine_data_json","time":1685724174324940162,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":319.0,"provider":"Smith Group","temperature":87.0,"topic":"machine\/machine3","vibration":473.0},{"iox::measurement":"machine_data_json","time":1685724174325470257,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":183.0,"provider":"Morales, Robinson and Newman","temperature":29.0,"topic":"machine\/machine1","vibration":69.0},{"iox::measurement":"machine_data_json","time":1685724174325535111,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":184.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":72.0},{"iox::measurement":"machine_data_json","time":1685724175325452588,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":308.0,"provider":"Smith Group","temperature":88.0,"topic":"machine\/machine3","vibration":478.0},{"iox::measurement":"machine_data_json","time":1685724175326241988,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":180.0,"provider":"Morales, Robinson and Newman","temperature":32.0,"topic":"machine\/machine1","vibration":67.0},{"iox::measurement":"machine_data_json","time":1685724175326458954,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":181.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":53.0},{"iox::measurement":"machine_data_json","time":1685724176325962575,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":301.0,"provider":"Smith Group","temperature":89.0,"topic":"machine\/machine3","vibration":366.0},{"iox::measurement":"machine_data_json","time":1685724176326547488,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":194.0,"provider":"Morales, Robinson and Newman","temperature":33.0,"topic":"machine\/machine1","vibration":77.0},{"iox::measurement":"machine_data_json","time":1685724176326817078,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":182.0,"provider":"Thomas and Sons","temperature":33.0,"topic":"machine\/machine2","vibration":54.0},{"iox::measurement":"machine_data_json","time":1685724177326651847,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":316.0,"provider":"Smith Group","temperature":82.0,"topic":"machine\/machine3","vibration":446.0},{"iox::measurement":"machine_data_json","time":1685724177326903277,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":186.0,"provider":"Morales, Robinson and Newman","temperature":32.0,"topic":"machine\/machine1","vibration":57.0},{"iox::measurement":"machine_data_json","time":1685724177327169455,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":183.0,"provider":"Thomas and Sons","temperature":33.0,"topic":"machine\/machine2","vibration":50.0},{"iox::measurement":"machine_data_json","time":1685724178327381372,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":303.0,"provider":"Smith Group","temperature":83.0,"topic":"machine\/machine3","vibration":329.0},{"iox::measurement":"machine_data_json","time":1685724178327785814,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":189.0,"provider":"Thomas and Sons","temperature":31.0,"topic":"machine\/machine2","vibration":54.0},{"iox::measurement":"machine_data_json","time":1685724178328075202,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":184.0,"provider":"Morales, Robinson and Newman","temperature":34.0,"topic":"machine\/machine1","vibration":67.0},{"iox::measurement":"machine_data_json","time":1685724179328107312,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":300.0,"provider":"Smith Group","temperature":90.0,"topic":"machine\/machine3","vibration":446.0},{"iox::measurement":"machine_data_json","time":1685724179328697178,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":196.0,"provider":"Thomas and Sons","temperature":32.0,"topic":"machine\/machine2","vibration":51.0},{"iox::measurement":"machine_data_json","time":1685724179328842456,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":183.0,"provider":"Morales, Robinson and Newman","temperature":30.0,"topic":"machine\/machine1","vibration":56.0},{"iox::measurement":"machine_data_json","time":1685724180328689987,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":300.0,"provider":"Smith Group","temperature":81.0,"topic":"machine\/machine3","vibration":460.0},{"iox::measurement":"machine_data_json","time":1685724180328730602,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":180.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":57.0},{"iox::measurement":"machine_data_json","time":1685724180329187607,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":187.0,"provider":"Morales, Robinson and Newman","temperature":33.0,"topic":"machine\/machine1","vibration":70.0},{"iox::measurement":"machine_data_json","time":1685724181329623051,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":194.0,"provider":"Thomas and Sons","temperature":33.0,"topic":"machine\/machine2","vibration":79.0},{"iox::measurement":"machine_data_json","time":1685724181329737661,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":314.0,"provider":"Smith Group","temperature":85.0,"topic":"machine\/machine3","vibration":441.0},{"iox::measurement":"machine_data_json","time":1685724181329994500,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":196.0,"provider":"Morales, Robinson and Newman","temperature":34.0,"topic":"machine\/machine1","vibration":70.0},{"iox::measurement":"machine_data_json","time":1685724182330561375,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":182.0,"provider":"Thomas and Sons","temperature":31.0,"topic":"machine\/machine2","vibration":66.0},{"iox::measurement":"machine_data_json","time":1685724182330611344,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":304.0,"provider":"Smith Group","temperature":89.0,"topic":"machine\/machine3","vibration":455.0},{"iox::measurement":"machine_data_json","time":1685724182330943808,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":186.0,"provider":"Morales, Robinson and Newman","temperature":29.0,"topic":"machine\/machine1","vibration":77.0},{"iox::measurement":"machine_data_json","time":1685724183331222016,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":319.0,"provider":"Smith Group","temperature":90.0,"topic":"machine\/machine3","vibration":459.0},{"iox::measurement":"machine_data_json","time":1685724183331373671,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":196.0,"provider":"Morales, Robinson and Newman","temperature":29.0,"topic":"machine\/machine1","vibration":60.0},{"iox::measurement":"machine_data_json","time":1685724183331578703,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":195.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":60.0},{"iox::measurement":"machine_data_json","time":1685724184331723999,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":311.0,"provider":"Smith Group","temperature":80.0,"topic":"machine\/machine3","vibration":493.0},{"iox::measurement":"machine_data_json","time":1685724184332158179,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":198.0,"provider":"Morales, Robinson and Newman","temperature":31.0,"topic":"machine\/machine1","vibration":71.0},{"iox::measurement":"machine_data_json","time":1685724184332222502,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":188.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":72.0},{"iox::measurement":"machine_data_json","time":1685724185332522723,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":305.0,"provider":"Smith Group","temperature":89.0,"topic":"machine\/machine3","vibration":442.0},{"iox::measurement":"machine_data_json","time":1685724185332606103,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":189.0,"provider":"Morales, Robinson and Newman","temperature":33.0,"topic":"machine\/machine1","vibration":71.0},{"iox::measurement":"machine_data_json","time":1685724185332956871,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":191.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":76.0},{"iox::measurement":"machine_data_json","time":1685724186332934234,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":313.0,"provider":"Smith Group","temperature":87.0,"topic":"machine\/machine3","vibration":470.0},{"iox::measurement":"machine_data_json","time":1685724186333179737,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":193.0,"provider":"Thomas and Sons","temperature":29.0,"topic":"machine\/machine2","vibration":74.0},{"iox::measurement":"machine_data_json","time":1685724186333464546,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":193.0,"provider":"Morales, Robinson and Newman","temperature":31.0,"topic":"machine\/machine1","vibration":61.0},{"iox::measurement":"machine_data_json","time":1685724187333538813,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":303.0,"provider":"Smith Group","temperature":86.0,"topic":"machine\/machine3","vibration":443.0},{"iox::measurement":"machine_data_json","time":1685724187333592979,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":197.0,"provider":"Thomas and Sons","temperature":33.0,"topic":"machine\/machine2","vibration":62.0},{"iox::measurement":"machine_data_json","time":1685724187333964542,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":197.0,"provider":"Morales, Robinson and Newman","temperature":29.0,"topic":"machine\/machine1","vibration":70.0},{"iox::measurement":"machine_data_json","time":1685724188333966919,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":308.0,"provider":"Smith Group","temperature":84.0,"topic":"machine\/machine3","vibration":330.0},{"iox::measurement":"machine_data_json","time":1685724188334168052,"host":"491cc20bbe13","load":13.0,"machineID":"machine2","power":195.0,"provider":"Thomas and Sons","temperature":31.0,"topic":"machine\/machine2","vibration":73.0},{"iox::measurement":"machine_data_json","time":1685724188334236775,"host":"491cc20bbe13","load":23.0,"machineID":"machine1","power":184.0,"provider":"Morales, Robinson and Newman","temperature":30.0,"topic":"machine\/machine1","vibration":73.0},{"iox::measurement":"machine_data_json","time":1685724189334998961,"host":"491cc20bbe13","load":120.0,"machineID":"machine3","power":303.0,"provider":"Smith Group","temperature":88.0,"topic":"machine\/machine3","vibration":395.0},{"iox::measurement":"machine_data_json","time":1685724189335091622,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":193.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":72.0},{"iox::measurement":"machine_data_json","time":1685724189335117396,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":201.0,"provider":"Morales, Robinson and Newman","temperature":37.0,"topic":"machine\/machine1","vibration":90.0},{"iox::measurement":"machine_data_json","time":1685724190335359448,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":209.0,"provider":"Smith Group","temperature":36.0,"topic":"machine\/machine3","vibration":89.0},{"iox::measurement":"machine_data_json","time":1685724190335917983,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":189.0,"provider":"Thomas and Sons","temperature":32.0,"topic":"machine\/machine2","vibration":58.0},{"iox::measurement":"machine_data_json","time":1685724190335961039,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":203.0,"provider":"Morales, Robinson and Newman","temperature":38.0,"topic":"machine\/machine1","vibration":85.0},{"iox::measurement":"machine_data_json","time":1685724191335865097,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":211.0,"provider":"Smith Group","temperature":39.0,"topic":"machine\/machine3","vibration":83.0},{"iox::measurement":"machine_data_json","time":1685724191336300844,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":194.0,"provider":"Thomas and Sons","temperature":29.0,"topic":"machine\/machine2","vibration":58.0},{"iox::measurement":"machine_data_json","time":1685724191336354602,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":205.0,"provider":"Morales, Robinson and Newman","temperature":38.0,"topic":"machine\/machine1","vibration":85.0},{"iox::measurement":"machine_data_json","time":1685724192336856584,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":213.0,"provider":"Smith Group","temperature":37.0,"topic":"machine\/machine3","vibration":88.0},{"iox::measurement":"machine_data_json","time":1685724192337596930,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":193.0,"provider":"Thomas and Sons","temperature":32.0,"topic":"machine\/machine2","vibration":55.0},{"iox::measurement":"machine_data_json","time":1685724192337627620,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":203.0,"provider":"Morales, Robinson and Newman","temperature":36.0,"topic":"machine\/machine1","vibration":81.0},{"iox::measurement":"machine_data_json","time":1685724193337427240,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":206.0,"provider":"Smith Group","temperature":38.0,"topic":"machine\/machine3","vibration":80.0},{"iox::measurement":"machine_data_json","time":1685724193337811242,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":184.0,"provider":"Thomas and Sons","temperature":32.0,"topic":"machine\/machine2","vibration":73.0},{"iox::measurement":"machine_data_json","time":1685724193337874112,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":201.0,"provider":"Morales, Robinson and Newman","temperature":40.0,"topic":"machine\/machine1","vibration":81.0},{"iox::measurement":"machine_data_json","time":1685724194337992849,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":217.0,"provider":"Smith Group","temperature":39.0,"topic":"machine\/machine3","vibration":89.0},{"iox::measurement":"machine_data_json","time":1685724194338326166,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":198.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":63.0},{"iox::measurement":"machine_data_json","time":1685724194338634931,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":205.0,"provider":"Morales, Robinson and Newman","temperature":37.0,"topic":"machine\/machine1","vibration":81.0},{"iox::measurement":"machine_data_json","time":1685724195339009274,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":210.0,"provider":"Smith Group","temperature":40.0,"topic":"machine\/machine3","vibration":80.0},{"iox::measurement":"machine_data_json","time":1685724195339100441,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":206.0,"provider":"Morales, Robinson and Newman","temperature":38.0,"topic":"machine\/machine1","vibration":90.0},{"iox::measurement":"machine_data_json","time":1685724195339762188,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":188.0,"provider":"Thomas and Sons","temperature":30.0,"topic":"machine\/machine2","vibration":55.0},{"iox::measurement":"machine_data_json","time":1685724196340230361,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":201.0,"provider":"Morales, Robinson and Newman","temperature":38.0,"topic":"machine\/machine1","vibration":84.0},{"iox::measurement":"machine_data_json","time":1685724196340650516,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":184.0,"provider":"Thomas and Sons","temperature":33.0,"topic":"machine\/machine2","vibration":64.0},{"iox::measurement":"machine_data_json","time":1685724196340991256,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":203.0,"provider":"Smith Group","temperature":37.0,"topic":"machine\/machine3","vibration":84.0},{"iox::measurement":"machine_data_json","time":1685724197341908770,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":211.0,"provider":"Smith Group","temperature":40.0,"topic":"machine\/machine3","vibration":84.0},{"iox::measurement":"machine_data_json","time":1685724197342360815,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":215.0,"provider":"Morales, Robinson and Newman","temperature":38.0,"topic":"machine\/machine1","vibration":86.0},{"iox::measurement":"machine_data_json","time":1685724197342426363,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":194.0,"provider":"Thomas and Sons","temperature":33.0,"topic":"machine\/machine2","vibration":62.0},{"iox::measurement":"machine_data_json","time":1685724198342445484,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":201.0,"provider":"Smith Group","temperature":36.0,"topic":"machine\/machine3","vibration":90.0},{"iox::measurement":"machine_data_json","time":1685724198342768157,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":197.0,"provider":"Thomas and Sons","temperature":30.0,"topic":"machine\/machine2","vibration":53.0},{"iox::measurement":"machine_data_json","time":1685724198342799655,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":211.0,"provider":"Morales, Robinson and Newman","temperature":36.0,"topic":"machine\/machine1","vibration":87.0},{"iox::measurement":"machine_data_json","time":1685724199342914561,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":206.0,"provider":"Smith Group","temperature":40.0,"topic":"machine\/machine3","vibration":80.0},{"iox::measurement":"machine_data_json","time":1685724199343415645,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":196.0,"provider":"Thomas and Sons","temperature":33.0,"topic":"machine\/machine2","vibration":53.0},{"iox::measurement":"machine_data_json","time":1685724199343478737,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":220.0,"provider":"Morales, Robinson and Newman","temperature":36.0,"topic":"machine\/machine1","vibration":89.0},{"iox::measurement":"machine_data_json","time":1685724200343479811,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":216.0,"provider":"Smith Group","temperature":36.0,"topic":"machine\/machine3","vibration":84.0},{"iox::measurement":"machine_data_json","time":1685724200344124763,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":193.0,"provider":"Thomas and Sons","temperature":32.0,"topic":"machine\/machine2","vibration":77.0},{"iox::measurement":"machine_data_json","time":1685724200344153596,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":200.0,"provider":"Morales, Robinson and Newman","temperature":35.0,"topic":"machine\/machine1","vibration":89.0},{"iox::measurement":"machine_data_json","time":1685724201343964197,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":212.0,"provider":"Smith Group","temperature":35.0,"topic":"machine\/machine3","vibration":86.0},{"iox::measurement":"machine_data_json","time":1685724201344617756,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":183.0,"provider":"Thomas and Sons","temperature":33.0,"topic":"machine\/machine2","vibration":64.0},{"iox::measurement":"machine_data_json","time":1685724201344685120,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":209.0,"provider":"Morales, Robinson and Newman","temperature":35.0,"topic":"machine\/machine1","vibration":86.0},{"iox::measurement":"machine_data_json","time":1685724202344825564,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":205.0,"provider":"Smith Group","temperature":39.0,"topic":"machine\/machine3","vibration":87.0},{"iox::measurement":"machine_data_json","time":1685724202345135145,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":184.0,"provider":"Thomas and Sons","temperature":31.0,"topic":"machine\/machine2","vibration":60.0},{"iox::measurement":"machine_data_json","time":1685724202345167055,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":220.0,"provider":"Morales, Robinson and Newman","temperature":38.0,"topic":"machine\/machine1","vibration":81.0},{"iox::measurement":"machine_data_json","time":1685724203345437181,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":200.0,"provider":"Smith Group","temperature":37.0,"topic":"machine\/machine3","vibration":86.0},{"iox::measurement":"machine_data_json","time":1685724203345506574,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":214.0,"provider":"Morales, Robinson and Newman","temperature":37.0,"topic":"machine\/machine1","vibration":86.0},{"iox::measurement":"machine_data_json","time":1685724203345564703,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":193.0,"provider":"Thomas and Sons","temperature":33.0,"topic":"machine\/machine2","vibration":62.0},{"iox::measurement":"machine_data_json","time":1685724204346349521,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":210.0,"provider":"Smith Group","temperature":37.0,"topic":"machine\/machine3","vibration":85.0},{"iox::measurement":"machine_data_json","time":1685724204346383833,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":211.0,"provider":"Morales, Robinson and Newman","temperature":37.0,"topic":"machine\/machine1","vibration":87.0},{"iox::measurement":"machine_data_json","time":1685724204346401291,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":193.0,"provider":"Thomas and Sons","temperature":32.0,"topic":"machine\/machine2","vibration":54.0},{"iox::measurement":"machine_data_json","time":1685724205346821289,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":220.0,"provider":"Smith Group","temperature":37.0,"topic":"machine\/machine3","vibration":89.0},{"iox::measurement":"machine_data_json","time":1685724205346921797,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":190.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":75.0},{"iox::measurement":"machine_data_json","time":1685724205347491870,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":214.0,"provider":"Morales, Robinson and Newman","temperature":39.0,"topic":"machine\/machine1","vibration":83.0},{"iox::measurement":"machine_data_json","time":1685724206347838431,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":186.0,"provider":"Thomas and Sons","temperature":29.0,"topic":"machine\/machine2","vibration":79.0},{"iox::measurement":"machine_data_json","time":1685724206348427616,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":200.0,"provider":"Morales, Robinson and Newman","temperature":40.0,"topic":"machine\/machine1","vibration":85.0},{"iox::measurement":"machine_data_json","time":1685724206348455741,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":205.0,"provider":"Smith Group","temperature":40.0,"topic":"machine\/machine3","vibration":80.0},{"iox::measurement":"machine_data_json","time":1685724207348535696,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":189.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":79.0},{"iox::measurement":"machine_data_json","time":1685724207349173287,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":215.0,"provider":"Morales, Robinson and Newman","temperature":36.0,"topic":"machine\/machine1","vibration":86.0},{"iox::measurement":"machine_data_json","time":1685724207349217288,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":213.0,"provider":"Smith Group","temperature":39.0,"topic":"machine\/machine3","vibration":83.0},{"iox::measurement":"machine_data_json","time":1685724208348964054,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":191.0,"provider":"Thomas and Sons","temperature":31.0,"topic":"machine\/machine2","vibration":63.0},{"iox::measurement":"machine_data_json","time":1685724208349958403,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":211.0,"provider":"Morales, Robinson and Newman","temperature":35.0,"topic":"machine\/machine1","vibration":84.0},{"iox::measurement":"machine_data_json","time":1685724208350213700,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":201.0,"provider":"Smith Group","temperature":38.0,"topic":"machine\/machine3","vibration":81.0},{"iox::measurement":"machine_data_json","time":1685724209349501656,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":190.0,"provider":"Thomas and Sons","temperature":30.0,"topic":"machine\/machine2","vibration":70.0},{"iox::measurement":"machine_data_json","time":1685724209350320992,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":209.0,"provider":"Morales, Robinson and Newman","temperature":35.0,"topic":"machine\/machine1","vibration":88.0},{"iox::measurement":"machine_data_json","time":1685724209350858026,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":204.0,"provider":"Smith Group","temperature":36.0,"topic":"machine\/machine3","vibration":82.0},{"iox::measurement":"machine_data_json","time":1685724210350640276,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":197.0,"provider":"Thomas and Sons","temperature":30.0,"topic":"machine\/machine2","vibration":55.0},{"iox::measurement":"machine_data_json","time":1685724210351158057,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":214.0,"provider":"Morales, Robinson and Newman","temperature":36.0,"topic":"machine\/machine1","vibration":90.0},{"iox::measurement":"machine_data_json","time":1685724210351331667,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":210.0,"provider":"Smith Group","temperature":39.0,"topic":"machine\/machine3","vibration":85.0},{"iox::measurement":"machine_data_json","time":1685724211351859842,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":188.0,"provider":"Thomas and Sons","temperature":29.0,"topic":"machine\/machine2","vibration":65.0},{"iox::measurement":"machine_data_json","time":1685724211352098083,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":214.0,"provider":"Morales, Robinson and Newman","temperature":35.0,"topic":"machine\/machine1","vibration":86.0},{"iox::measurement":"machine_data_json","time":1685724211352141060,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":213.0,"provider":"Smith Group","temperature":37.0,"topic":"machine\/machine3","vibration":84.0},{"iox::measurement":"machine_data_json","time":1685724212352201239,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":195.0,"provider":"Thomas and Sons","temperature":32.0,"topic":"machine\/machine2","vibration":56.0},{"iox::measurement":"machine_data_json","time":1685724212352517261,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":205.0,"provider":"Morales, Robinson and Newman","temperature":37.0,"topic":"machine\/machine1","vibration":84.0},{"iox::measurement":"machine_data_json","time":1685724212352589820,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":215.0,"provider":"Smith Group","temperature":36.0,"topic":"machine\/machine3","vibration":85.0},{"iox::measurement":"machine_data_json","time":1685724213352642145,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":187.0,"provider":"Thomas and Sons","temperature":34.0,"topic":"machine\/machine2","vibration":68.0},{"iox::measurement":"machine_data_json","time":1685724213353162708,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":218.0,"provider":"Morales, Robinson and Newman","temperature":35.0,"topic":"machine\/machine1","vibration":82.0},{"iox::measurement":"machine_data_json","time":1685724213353192522,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":205.0,"provider":"Smith Group","temperature":36.0,"topic":"machine\/machine3","vibration":89.0},{"iox::measurement":"machine_data_json","time":1685724214353255548,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":197.0,"provider":"Thomas and Sons","temperature":31.0,"topic":"machine\/machine2","vibration":50.0},{"iox::measurement":"machine_data_json","time":1685724214353521359,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":205.0,"provider":"Morales, Robinson and Newman","temperature":38.0,"topic":"machine\/machine1","vibration":80.0},{"iox::measurement":"machine_data_json","time":1685724214353592745,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":202.0,"provider":"Smith Group","temperature":38.0,"topic":"machine\/machine3","vibration":83.0},{"iox::measurement":"machine_data_json","time":1685724215353829588,"host":"491cc20bbe13","load":21.0,"machineID":"machine2","power":186.0,"provider":"Thomas and Sons","temperature":30.0,"topic":"machine\/machine2","vibration":68.0},{"iox::measurement":"machine_data_json","time":1685724215354477346,"host":"491cc20bbe13","load":53.0,"machineID":"machine3","power":215.0,"provider":"Smith Group","temperature":36.0,"topic":"machine\/machine3","vibration":84.0},{"iox::measurement":"machine_data_json","time":1685724215354644118,"host":"491cc20bbe13","load":51.0,"machineID":"machine1","power":206.0,"provider":"Morales, Robinson and Newman","temperature":38.0,"topic":"machine\/machine1","vibration":85.0}] \ No newline at end of file From 16221ea2d650126e3d192bae2357dcc93d24b0aa Mon Sep 17 00:00:00 2001 From: karel rehor Date: Wed, 18 Sep 2024 14:33:02 +0200 Subject: [PATCH 8/9] docs: update write example in README.md --- README.md | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/README.md b/README.md index 7fee9fc..c4df8eb 100644 --- a/README.md +++ b/README.md @@ -92,7 +92,11 @@ from influxdb_client_3 import write_client_options, WritePrecision, WriteOptions class BatchingCallback(object): + def __init__(self): + self.write_count = 0 + def success(self, conf, data: str): + self.write_count += 1 print(f"Written batch: {conf}, data: {data}") def error(self, conf, data: str, exception: InfluxDBError): @@ -103,7 +107,7 @@ class BatchingCallback(object): callback = BatchingCallback() -write_options = WriteOptions(batch_size=500, +write_options = WriteOptions(batch_size=100, flush_interval=10_000, jitter_interval=2_000, retry_interval=5_000, @@ -128,10 +132,7 @@ with InfluxDBClient3.InfluxDBClient3( file='./out.csv', timestamp_column='time', tag_columns=["provider", "machineID"]) - client.write_file( - file='./out.json', - timestamp_column='time', tag_columns=["provider", "machineID"], date_unit='ns' ) - +print(f'DONE writing from csv in {callback.write_count} batch(es)') ``` From 232b4d3988d4767ef3106447c33f47e16e7173fa Mon Sep 17 00:00:00 2001 From: karel rehor Date: Wed, 18 Sep 2024 15:13:23 +0200 Subject: [PATCH 9/9] docs: update CHANGELOG.md --- CHANGELOG.md | 1 + 1 file changed, 1 insertion(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index 877ae5f..7cd449b 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,6 +5,7 @@ ### Features 1. [#108](https://github.com/InfluxCommunity/influxdb3-python/pull/108): Better expose access to response headers in `InfluxDBError`. Example `handle_http_error` added. +2. [#112](https://github.com/InfluxCommunity/influxdb3-python/pull/112): Update batching examples, add integration tests of batching. ### Bug Fixes