Skip to content
Snippets Groups Projects
Commit 5b072284 authored by Sven-Ove Hänsel's avatar Sven-Ove Hänsel
Browse files

new branch

parent f77c34b3
No related branches found
No related tags found
No related merge requests found
Showing
with 13 additions and 2 deletions
File mode changed from 100644 to 100755
README.md 100644 → 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
...@@ -9,8 +9,19 @@ port = int(os.getenv('mos_port',default="1883")) ...@@ -9,8 +9,19 @@ port = int(os.getenv('mos_port',default="1883"))
lines_per_window = int(os.getenv('lines_per_window',default="1000")) lines_per_window = int(os.getenv('lines_per_window',default="1000"))
path = str(os.getenv('path_data',default='C:\\Studium_MIN\\05_Masterarbeit\\thesis\\ma_code\\code\\infrastructure\\streaming\\clients\\pub\\data\\')) path = str(os.getenv('path_data',default='C:\\Studium_MIN\\05_Masterarbeit\\thesis\\ma_code\\code\\infrastructure\\streaming\\clients\\pub\\data\\'))
files = ['ta1-cadets-e3-official_1.json', 'ta1-cadets-e3-official_2.json', 'ta1-cadets-e3-official_3.json'] files = [
line_count = [4999999,4999999,3911712] # line_count corresponding to each file 'ta1-cadets-e3-official_0.json',
'ta1-cadets-e3-official_1.json',
'ta1-cadets-e3-official_2.json',
'ta1-cadets-e3-official-1_0.json',
'ta1-cadets-e3-official-1_1.json',
'ta1-cadets-e3-official-1_2.json',
'ta1-cadets-e3-official-1_3.json',
'ta1-cadets-e3-official-1_4.json',
'ta1-cadets-e3-official-2_0.json',
'ta1-cadets-e3-official-2_1.json'
]
line_count = [4999999,4999999,3911712,4999999,4999999,4999999,4999999,4999999,2059063,4999999,34335661] # line_count corresponding to each file
sleep_time = 2 sleep_time = 2
client = mqtt.Client("Client1") client = mqtt.Client("Client1")
topic = "neo4j" topic = "neo4j"
......
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
File mode changed from 100644 to 100755
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment