Running from python shell

deploy@workflow-00:~/airflow/dags$ python
Python 2.7.6 (default, Jun 22 2015, 17:58:13) 
[GCC 4.8.2] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> import generate_spoofs.generate_spoofed_message
>>> generate_spoofs.generate_spoofed_message.main()
--- Injecting Record ---
{'spf_result': '', 'from': '[email protected]', 'timestamp': '2015-10-24 02:24:25', 'mfrom': '', 'dmarc_result': '', 'msg_id': '<[email protected]>', 'to': '[email protected]', 'ip': '207.46.100.71', 'dkim_s': '', 'dkim_result': '', 'dkim_d': '', 'subject': '[Expensify] Please approve and forward expense report "%{month} Expenses"'}
{"body": "ApT46/cKAkhmYTZlNzI2MS1kYzc0LTRkY2ItYmQ3My0wOWY5OThmZmZjZGKU+Ov3CgAaMjA3LjQ2LjEwMC43MQIaMjA3LjQ2LjEwMC43MQAcZXhwZW5zaWlmeS5jb20CAAACAAIAACR2YXBwYXJhb0BhZ2FyaS5jb20AAAAAAF5pcC0xMC00NC0wLTIxMi51cy13ZXN0LTIuY29tcHV0ZS5pbnRlcm5hbFx1MDAwMAAAAAAAAAB+PGZhY2FkZTJjODc5NTRmOWM5MWM3NTVkMTdmMTEzNGNiQEJZMlBSMTJNQjAwNTQuZXhwZW5zaWlmeS5jb20+ALgBVzBWNGNHVnVjMmxtZVYwZ1VHeGxZWE5sSUdGd2NISnZkbVVnWVc1a0lHWnZjbmRoY21RZ1pYaHdaVzV6WlNCeVpYQnZjblFnSWtwMWJIa2dSWGh3Wlc1elpYTWkAJmhlbHBAZXhwZW5zaWlmeS5jb20AAAAAJHZhcHBhcmFvQGFnYXJpLmNvbQICACZoZWxwQGV4cGVuc2lpZnkuY29tACR2YXBwYXJhb0BhZ2FyaS5jb20AAAAAAAJIMzA0MzIxZWUtNDNjNC0xMWU2LTk4NGEtMDI5ZjA0ODM4MzE3AA==", "head": {"schema_id": "fb9d6e3becab3f7d"}}
--- Kinesis Result ---
{u'ShardId': u'shardId-000000000389', 'ResponseMetadata': {'HTTPStatusCode': 200, 'RequestId': '30461899-43c4-11e6-879b-1928d272edd7'}, u'SequenceNumber': u'49563449982884727797497064821151117445928190189632493650'}
---
--- Injecting Record ---
{'spf_result': '', 'from': '[email protected]', 'timestamp': '2015-10-24 21:29:13', 'mfrom': '', 'dmarc_result': '', 'msg_id': '<[email protected]>', 'to': '[email protected]', 'ip': '209.85.223.178', 'dkim_s': '', 'dkim_result': '', 'dkim_d': '', 'subject': 'Fwd: EMEA Event Sponsorship'}
{"body": "ApT46/cKAkhmYTZlNzI2MS1kYzc0LTRkY2ItYmQ3My0wOWY5OThmZmZjZGKU+Ov3CgAcMjA5Ljg1LjIyMy4xNzgCHDIwOS44NS4yMjMuMTc4ABRhYWdhcmkuY29tAgAAAgACAAAga2FuZHJlQGFnYXJpLmNvbQAAAAAAXmlwLTEwLTQ0LTAtMjEyLnVzLXdlc3QtMi5jb21wdXRlLmludGVybmFsXHUwMDAwAAAAAAAAAHY8ZmFjYWRlMTg1ZDc0YjE5ZDY3N2YzYjgxMjI1NTU5YzlAQlkyUFIxMk1CMDA1NC5hYWdhcmkuY29tPgBIUm5ka09pQkZUVVZCSUVWMlpXNTBJRk53YjI1emIzSnphR2x3AChwcGV0ZXJzb25AYWFnYXJpLmNvbQAAAAAga2FuZHJlQGFnYXJpLmNvbQICAChwcGV0ZXJzb25AYWFnYXJpLmNvbQAga2FuZHJlQGFnYXJpLmNvbQAAAAAAAkgzMDQ5MGJhZS00M2M0LTExZTYtOTg0YS0wMjlmMDQ4MzgzMTcA", "head": {"schema_id": "fb9d6e3becab3f7d"}}
--- Kinesis Result ---
{u'ShardId': u'shardId-000000000386', 'ResponseMetadata': {'HTTPStatusCode': 200, 'RequestId': '30499b43-43c4-11e6-879b-1928d272edd7'}, u'SequenceNumber': u'49563449949991128629664395687394395474509159372534323234'}
---