# Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. # SPDX-License-Identifier: MIT-0 from shared.defines import * from shared.environ import * from shared.helpers import * from shared.message import Message from shared.document import Document from shared.database import Database from shared.store import Store from shared.bus import Bus def lambda_handler(event, context): document = Document.from_dict(event) message = Message(DocumentID = document.DocumentID) Logger.info(f'{STAGE} Actor : Started Processing DocumentID = {document.DocumentID}') # Store.PutFile(Store.GetFile()) message.FinalStamp = GetCurrentStamp() Bus.PutMessage(stage = STAGE, message_body = message.to_json()) Logger.info(f'{STAGE} Actor : Stopped Processing DocumentID = {document.DocumentID}') return PASS if __name__ == '__main__': Bus.Purge(stage = STAGE) lambda_handler(Document(DocumentID = '001', AcquireMap = dict(InputS3Url = 'acquire/1/001.pdf')).to_dict(), None)