Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- application.py
- -services
- parser.py
- -models
- hl7message.py
- from mongoengine import connect
- import os, os.path, time
- from services import parser
- db = connect('testdb')
- dr = 'C:\Imports\Processed'
- def processimports():
- while True:
- files = os.listdir(dr)
- print(str(len(files)) + ' files found')
- for f in files:
- msg = open(dr + '\' + f).read().replace('n', 'r')
- parser.parse_message(msg)
- print('waiting')
- time.sleep(10)
- processimports()
- import hl7
- from models import hl7message
- def parse_message(message):
- m = hl7.parse(str(message))
- h = hl7message()
- from utilities import common
- from application import db
- import mongoengine
- class Hl7message(db.Document):
- message_type = db.StringField(db_field="m_typ")
- created = db.IntField(db_field="cr")
- message = db.StringField(db_field="m")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement