Добавить «запись» в файл JSON с Python

Question

Мне нужно изменить JSON-файл с помощью python. Когда я впервые работаю с python (и JSON), я прочитал некоторые статьи об этом, но не понял его полностью.

Мне удалось импортировать JSON в python, как какой-то массив (или список?).

JSON выглядит следующим образом:

{ 
    "sources":[{ 
    "id":100012630, 
    "name":"Activity Login Page", 
    "category":"NAM/Activity", 
    "automaticDateParsing":true, 
    "multilineProcessingEnabled":false, 
    "useAutolineMatching":false, 
    "forceTimeZone":true, 
    "timeZone":"Europe/Brussels", 
    "filters":[], 
    "cutoffTimestamp":1414364400000, 
    "encoding":"UTF-8", 
    "pathExpression":"C:\\NamLogs\\nam-login-page.log*", 
    "blacklist":[], 
    "sourceType":"LocalFile", 
    "alive":true 
    },{ 
    "id":100001824, 
    "name":"localWinEvent", 
    "category":"NAM/OS/EventLog", 
    "automaticDateParsing":true, 
    "multilineProcessingEnabled":false, 
    "useAutolineMatching":false, 
    "forceTimeZone":false, 
    "filters":[], 
    "cutoffTimestamp":1409090400000, 
    "encoding":"UTF-8", 
    "logNames":["Security","Application","System","Others"], 
    "sourceType":"LocalWindowsEventLog", 
    "alive":true 
    },{ 
    "id":100001830, 
    "name":"localWinPerf", 
    "category":"NAM/OS/Perf", 
    "automaticDateParsing":false, 
    "multilineProcessingEnabled":false, 
    "useAutolineMatching":false, 
    "forceTimeZone":false, 
    "filters":[], 
    "cutoffTimestamp":0, 
    "encoding":"UTF-8", 
    "interval":60000, 
    "wmiQueries":[{ 
     "name":"NAMID Service", 
     "query":"SELECT * FROM Win32_PerfRawData_PerfProc_Process WHERE Name = 'tomcat7'" 
    },{ 
     "name":"CPU", 
     "query":"select * from Win32_PerfFormattedData_PerfOS_Processor" 
    },{ 
     "name":"Logical Disk", 
     "query":"select * from Win32_PerfFormattedData_PerfDisk_LogicalDisk" 
    },{ 
     "name":"Physical Disk", 
     "query":"select * from Win32_PerfFormattedData_PerfDisk_PhysicalDisk" 
    },{ 
     "name":"Memory", 
     "query":"select * from Win32_PerfFormattedData_PerfOS_Memory" 
    },{ 
     "name":"Network", 
     "query":"select * from Win32_PerfFormattedData_Tcpip_NetworkInterface" 
    }], 
    "sourceType":"LocalWindowsPerfMon", 
    "alive":true 
    }, 

Теперь, когда я получил сотни файлов, как те, что я написал Еогеасп через весь каталог:

for filename in os.listdir('./json/'): 
    with open('./json/'+filename) as data_file:  
    sources = json.load(data_file) 

Теперь мне нужно что-то вроде снова источник foreach в источниках, который добавляет строку (или запись или что-то вроде «строки» в JSON) для каждого источника (что-то вроде collectorName = имя_файла), а затем перезаписывает старый файл новым.

JSON будет выглядеть следующим образом:

{ 
     "sources":[{ 
     "id":100012630, 
     "name":"Activity Login Page", 
     "category":"NAM/Activity", 
     "automaticDateParsing":true, 
     "multilineProcessingEnabled":false, 
     "useAutolineMatching":false, 
     "forceTimeZone":true, 
     "timeZone":"Europe/Brussels", 
     "filters":[], 
     "cutoffTimestamp":1414364400000, 
     "encoding":"UTF-8", 
     "pathExpression":"C:\\NamLogs\\nam-login-page.log*", 
     "blacklist":[], 
     "sourceType":"LocalFile", 
     "alive":true, 
     "collectorName":"Collector2910" 
     },{ 
     "id":100001824, 
     "name":"localWinEvent", 
     "category":"NAM/OS/EventLog", 
     "automaticDateParsing":true, 
     "multilineProcessingEnabled":false, 
     "useAutolineMatching":false, 
     "forceTimeZone":false, 
     "filters":[], 
     "cutoffTimestamp":1409090400000, 
     "encoding":"UTF-8", 
     "logNames":["Security","Application","System","Others"], 
     "sourceType":"LocalWindowsEventLog", 
     "alive":true, 
     "collectorName":"Collector2910" 
     },{..... 

Я надеюсь, что я мог бы объяснить мою проблему, и я был бы рад, если кто-то может мне помочь (даже с совершенно иным решением).

Заранее спасибо

Майкл

Answer 1

Вот один из способов сделать это:

for filename in os.listdir('./json/'): 
    sources = None 
    with open('./json/'+filename) as data_file:  
     sources = json.load(data_file) 
     sourcelist = sources['sources'] 
     for i, s in enumerate(sourcelist): 
      sources['sources'][i]['collectorName'] = 'Collector' + str(i) 
    with open('./json/'+filename, 'w') as data_file: 
     data_file.write(json.dumps(sources)) 

Answer 2

for filename in os.listdir('./json/'): 
    with open('./json/'+filename) as data_file:  
     datadict = json.load(data_file) 
    # At this point you have a plain python dict. 
    # This dict has a 'sources' key, pointing to 
    # a list of dicts. What you want is to add 
    # a 'collectorName': filename key:value pair 
    # to each of these dicts 
    for record in datadict["sources"]: 
     record["collectorName"] = filename 
    # now you just have to serialize your datadict back 
    # to json and write it back to the file - which is 
    # in fact a single operation 
    with open('./json/'+filename, "w") as data_file:  
     json.dump(datadict, data_file)