def _process_document_created_event()

in code/embedding-function/file_processing.py [0:0]


def _process_document_created_event(message_body) -> None:
    env_helper: EnvHelper = EnvHelper()

    blob_client = AzureBlobStorageClient()
    file_name = _get_file_name_from_message(message_body)
    file_sas = blob_client.get_blob_sas(file_name)
    sharepoint_file_id = str(message_body.get("sharepointFileId"))

    logger.info("_process_document_created_event : %s - %s - %s", file_name, file_sas, sharepoint_file_id)
    embedder = EmbedderFactory.create(env_helper)
    embedder.embed_file(file_sas, file_name, sharepoint_file_id)