fetch schemas from EventBridge

fetch_eventbridge_schema.py

import json
import shlex
import subprocess as sp
from pprint import pprint

registry = "foo"

schema_name = "bar"

cmd = f"aws schemas describe-schema --registry-name={registry} --schema-name={schema_name}"

process = sp.run(shlex.split(cmd), capture_output=True)

captured_json = json.loads(process.stdout)

schema = json.loads(captured_json["Content"])

pprint(schema)