projects
/
osm
/
NG-SA.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Enable pylint in NG-SA
[osm/NG-SA.git]
/
osm_webhook_translator
/
src
/
osm_webhook_translator
/
main.py
diff --git
a/osm_webhook_translator/src/osm_webhook_translator/main.py
b/osm_webhook_translator/src/osm_webhook_translator/main.py
index
587fa9c
..
7c4404c
100644
(file)
--- a/
osm_webhook_translator/src/osm_webhook_translator/main.py
+++ b/
osm_webhook_translator/src/osm_webhook_translator/main.py
@@
-15,6
+15,7
@@
# limitations under the License.
#######################################################################################
from datetime import datetime
# limitations under the License.
#######################################################################################
from datetime import datetime
+import logging
import os
from random import randint
import os
from random import randint
@@
-22,6
+23,12
@@
from fastapi import FastAPI
import requests
import requests
+logging.basicConfig(
+ format="%(asctime)s %(levelname)s %(filename)s:%(lineno)s %(message)s",
+ datefmt="%Y/%m/%d %H:%M:%S",
+)
+logger = logging.getLogger(__name__)
+logger.setLevel(logging.INFO)
app = FastAPI()
app = FastAPI()
@@
-37,17
+44,17
@@
def send_to_airflow(output_endpoint, content):
rnd = str(randint(0, 999999)).rjust(6, "0")
timestamp = datetime.now().strftime("%Y%m%d%H%M%S")
dag_run_id = output_endpoint + "_" + timestamp + "_" + rnd
rnd = str(randint(0, 999999)).rjust(6, "0")
timestamp = datetime.now().strftime("%Y%m%d%H%M%S")
dag_run_id = output_endpoint + "_" + timestamp + "_" + rnd
-
print(f"HTTP POST {url}...
")
+
logger.info(f"HTTP POST {url}
")
req = requests.post(
url=url,
auth=(airflow_user, airflow_pass),
json={"dag_run_id": dag_run_id, "conf": content},
)
req = requests.post(
url=url,
auth=(airflow_user, airflow_pass),
json={"dag_run_id": dag_run_id, "conf": content},
)
-
print(req.text
)
+
logger.info(f"Response: {req.text}"
)
# timeout and retries
except Exception as e:
# timeout and retries
except Exception as e:
-
print
(f"HTTP error: {repr(e)}")
- raise requests.HTTPE
xception
(status_code=403, detail=repr(e))
+
logger.error
(f"HTTP error: {repr(e)}")
+ raise requests.HTTPE
rror
(status_code=403, detail=repr(e))
@app.post("/{input_endpoint}")
@app.post("/{input_endpoint}")