Advertisement
Guest User

Untitled

a guest
Dec 7th, 2016
50
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.87 KB | None | 0 0
  1. application.py
  2. -services
  3. parser.py
  4. -models
  5. hl7message.py
  6.  
  7. from mongoengine import connect
  8. import os, os.path, time
  9. from services import parser
  10.  
  11. db = connect('testdb')
  12. dr = 'C:\Imports\Processed'
  13.  
  14. def processimports():
  15. while True:
  16. files = os.listdir(dr)
  17. print(str(len(files)) + ' files found')
  18. for f in files:
  19. msg = open(dr + '\' + f).read().replace('n', 'r')
  20. parser.parse_message(msg)
  21.  
  22. print('waiting')
  23. time.sleep(10)
  24.  
  25. processimports()
  26.  
  27. import hl7
  28. from models import hl7message
  29.  
  30. def parse_message(message):
  31. m = hl7.parse(str(message))
  32. h = hl7message()
  33.  
  34. from utilities import common
  35. from application import db
  36. import mongoengine
  37.  
  38. class Hl7message(db.Document):
  39. message_type = db.StringField(db_field="m_typ")
  40. created = db.IntField(db_field="cr")
  41. message = db.StringField(db_field="m")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement