in src/qldb_streaming_to_es_sample/app.py [0:0]
def __create_document(fields, revision_data): document = {} for field in fields: document[field] = revision_data[field] return document