From 9dd8a819137e708ad1c8f8476efca95f70f5bb58 Mon Sep 17 00:00:00 2001 From: marcsello Date: Wed, 24 Nov 2021 21:25:55 +0100 Subject: [PATCH] added something --- evaluation_server.py | 4 ++++ push_csirip.py | 7 +++++++ 2 files changed, 11 insertions(+) diff --git a/evaluation_server.py b/evaluation_server.py index 58a823c..df3cf46 100644 --- a/evaluation_server.py +++ b/evaluation_server.py @@ -1,7 +1,9 @@ +import logging from flask import Flask, request, abort, Response import json app = Flask(__name__) +app.logger.setLevel(logging.DEBUG) @app.route('/', methods=['POST']) @@ -26,6 +28,8 @@ def record(): with open("arrived.txt", "at") as f: f.write(f"{desc['device_id']}\n") + app.logger.info(f"Arrived: {desc['device_id']}") + return Response(status=200) diff --git a/push_csirip.py b/push_csirip.py index 2afa9dc..a46eba7 100644 --- a/push_csirip.py +++ b/push_csirip.py @@ -1,4 +1,6 @@ #!/usr/bin/env python3 +import sys +import time import requests import os import os.path @@ -7,6 +9,9 @@ from datetime import datetime def main(): + + sleep_time = int(sys.argv[1]) + for root, _, files in os.walk("big_chop_output/"): for file in files: full_filename = os.path.join(root,file) @@ -24,6 +29,8 @@ def main(): r = requests.post("http://127.0.0.1:8000/filter", files=files) r.raise_for_status() + if sleep_time > 0: + time.sleep(sleep_time) if __name__ == '__main__':