diff --git a/config-sample.py b/config-sample.py index 87b92bc..b7d3082 100644 --- a/config-sample.py +++ b/config-sample.py @@ -1,4 +1,6 @@ # MongoDB Database parameters CONNECTION_STRING = "mongodb://user:pass@mongoserver:27017/database" +DATABASE = "uparcel" +COLLECTION = "job-status-log" diff --git a/push.py b/push.py new file mode 100644 index 0000000..6c53555 --- /dev/null +++ b/push.py @@ -0,0 +1,15 @@ +from pymongo import MongoClient +from config import * +import sys +import json + +def push(document): + client = MongoClient(CONNECTION_STRING) + database = client[DATABASE] + collection = database[COLLECTION] + collection.insert_one(document) + + +if __name__ == '__main__': + push(json.loads(sys.argv[1])) +