In [1]:

    

from pymongo import MongoClient
import json

MONGO_CONFIG = {'host': 'localhost', 'port': 27017}
        
def import_json(filename):
    recorded_impressions = MongoClient(**MONGO_CONFIG).kinesis_traffic.recorded_impressions
    with open(filename, 'r') as jsonfile:
        for line in jsonfile.readlines():
            jsonline = json.loads(line)
            print(jsonline)
            
import_json("filename.json")


    

    




[LOG] FAIL 2 matches for test 1 of 
	row:
 {'count': 2, '_id': {'offer_contract_id': 8649, 'device_id': 11249, 'campaign_id': 21956, 'browser_version_minor_id': 51, 'language_id': 67, 'traffic_type_id': 1, 'operating_system_version_minor_id': 239, 'publisher_id': 6646, 'creative_id': 14084, 'offer_id': 8109, 'test': False, 'click_pixel': False, 'subid_1': 'AT_6646/RA20161026-1100'}}
	query:
select offer_contract_id,device_id,campaign_id,browser_version_minor_id,language_id,traffic_type_id,operating_system_version_minor_id,publisher_id,creative_id,offer_id,test,click_pixel,subid_1 
from cake_demo_affiliate_main_temp.traffic_events_v6
 where offer_contract_id = 8649
and device_id = 11249
and campaign_id = 21956
and browser_version_minor_id = 51
and language_id = 67
and traffic_type_id = 1
and operating_system_version_minor_id = 239
and publisher_id = 6646
and creative_id = 14084
and offer_id = 8109
and test = False
and click_pixel = False
and subid_1 = 'AT_6646/RA20161026-1100'

[LOG] PASS for test 2
[LOG] PASS for test 3
[LOG] PASS for test 4
[LOG] PASS for test 5
[LOG] PASS for test 6
[LOG] PASS for test 7
[LOG] PASS for test 8
[LOG] PASS for test 9
[LOG] PASS for test 10
[LOG] PASS for test 11
[LOG] PASS for test 12
[LOG] PASS for test 13
[LOG] PASS for test 14
[LOG] PASS for test 15
[LOG] PASS for test 16
[LOG] PASS for test 17
[LOG] PASS for test 18
[LOG] PASS for test 19
[LOG] PASS for test 20
[LOG] PASS for test 21
[LOG] PASS for test 22
[LOG] PASS for test 23
[LOG] PASS for test 24
[LOG] PASS for test 25
[LOG] PASS for test 26
[LOG] PASS for test 27
[LOG] PASS for test 28
[LOG] PASS for test 29
[LOG] PASS for test 30
[LOG] PASS for test 31
[LOG] PASS for test 32
[LOG] PASS for test 33
[LOG] PASS for test 34
[LOG] PASS for test 35
[LOG] PASS for test 36
[LOG] PASS for test 37
[LOG] PASS for test 38
[LOG] PASS for test 39
[LOG] PASS for test 40
[LOG] PASS for test 41
[LOG] PASS for test 42
[LOG] PASS for test 43
[LOG] PASS for test 44
[LOG] PASS for test 45
[LOG] PASS for test 46
[LOG] PASS for test 47
[LOG] PASS for test 48
[LOG] PASS for test 49
[LOG] PASS for test 50
[LOG] PASS for test 51
[LOG] PASS for test 52
[LOG] PASS for test 53
[LOG] PASS for test 54
[LOG] PASS for test 55
[LOG] PASS for test 56
[LOG] PASS for test 57
[LOG] PASS for test 58
[LOG] PASS for test 59
[LOG] PASS for test 60
[LOG] PASS for test 61
[LOG] PASS for test 62
[LOG] PASS for test 63
[LOG] PASS for test 64
[LOG] PASS for test 65
[LOG] PASS for test 66
[LOG] PASS for test 67
[LOG] PASS for test 68
[LOG] PASS for test 69
[LOG] PASS for test 70
[LOG] PASS for test 71
[LOG] PASS for test 72
[LOG] PASS for test 73
[LOG] PASS for test 74
[LOG] PASS for test 75
[LOG] PASS for test 76
[LOG] PASS for test 77
[LOG] PASS for test 78
[LOG] PASS for test 79
[LOG] PASS for test 80
[LOG] PASS for test 81
[LOG] PASS for test 82
[LOG] PASS for test 83
[LOG] PASS for test 84
[LOG] PASS for test 85
[LOG] PASS for test 86
[LOG] PASS for test 87
[LOG] PASS for test 88
[LOG] PASS for test 89
[LOG] PASS for test 90
[LOG] PASS for test 91
[LOG] PASS for test 92
[LOG] PASS for test 93
[LOG] PASS for test 94
[LOG] PASS for test 95
[LOG] PASS for test 96
[LOG] PASS for test 97
[LOG] PASS for test 98
[LOG] PASS for test 99
[LOG] PASS for test 100
[LOG] PASS for test 101
[LOG] PASS for test 102
[LOG] PASS for test 103
[LOG] PASS for test 104
[LOG] PASS for test 105
[LOG] PASS for test 106
[LOG] PASS for test 107
[LOG] PASS for test 108
[LOG] PASS for test 109