kw_tools_yover/hhh/aws-monitor/cl-test.py

import subprocess
import json
import sys
import io
cmd='aws cloudtrail lookup-events --lookup-attributes AttributeKey=EventName,AttributeValue=RunInstances --max-results 20 --region us-east-1'
cmds=cmd.split(' ')
#cl=subprocess.run(cmds,text=True, capture_output=True)
cl=subprocess.Popen(cmds, stdout=subprocess.PIPE)
lst=[]

def proc_l(l):
    return l.replace(',','').replace('\n','').strip()

js="{"
for l in io.TextIOWrapper(cl.stdout, encoding="utf-8"):
    if '"EventId":' in l:
        js+=proc_l(l)
        lst.append(proc_l(l))

    if '"EventTime":' in l:
        js+=proc_l(l)
        js+="}"
        print(js)
        js2=json.loads(js)
        print(js2)
        js="{"
        lst.append(proc_l(l))

    if '"AccessKeyId":' in l:
        js+=proc_l(l)
    
        lst.append(proc_l(l))

    if '"EventName":' in l:
        js+=proc_l(l)

        lst.append(proc_l(l))
#lines = cl.stdout.readlines()
#clstr=str(cl)
#lines=clstr.split('\n')



#print(lst)

#        print(l)
#        sys.exit()
#js=json.loads(str(cl))
#print(js)