Technical Thoughts

 import asyncio import azure.functions as func import logging import json import functools import multiples_sales_caliberation import multiples_ebitda_caliberation import multiples_sales_liquidity import multiples_ebitda_liquidity import gorden_growth import dcf_exit_multiples_sales import dcf_exit_multiples_ebitda import extract_document_data import asset_sensitivity_check from response_handling import handle_error, handle_success from fn_pwc_cit_rates_scaper_bronze import bp as cit_bronze_scraper from fn_cit_rates_bronze_silver_transformation import bp as cit_bronze_silver_transformation from fn_risk_premium_scraper_bronze import bp as risk_premium_scraper_bronze from fn_risk_premium_bronze_gold_transformation import bp as risk_premium_bronze_gold_transformation from connection import send_restapi_message,notify_and_handle_errors app = func.FunctionApp(http_auth_level=func.AuthLevel.FUNCTION) app.register_functions(cit_bronze_scraper)  app.register_functions(cit_bronze_silve...

  import asyncio import azure . functions as func import logging import json import functools import multiples_sales_caliberation import multiples_ebitda_caliberation import multiples_sales_liquidity import multiples_ebitda_liquidity import gorden_growth import dcf_exit_multiples_sales import dcf_exit_multiples_ebitda import extract_document_data import asset_sensitivity_check from response_handling import handle_error , handle_success from fn_pwc_cit_rates_scaper_bronze import bp as cit_bronze_scraper from fn_cit_rates_bronze_silver_transformation import bp as cit_bronze_silver_transformation from fn_risk_premium_scraper_bronze import bp as risk_premium_scraper_bronze from fn_risk_premium_bronze_gold_transformation import bp as risk_premium_bronze_gold_transformation from connection import send_restapi_message , notify_and_handle_errors , get_engine , get_connection_details from constants import STORED_PROCEDURES from sqlalchemy impor...

 Connection.py Inorder to run it locally you can change the Verify=False.And while pushing to Azure function or to git make it True import base64 import functools import azure . functions as func import hashlib import hmac import json import logging import os import time import httpx import requests import sqlalchemy import pyodbc # Get the Azure Function logger logger = logging . getLogger ( __name__ ) logger . info ( f "__name__ { __name__ } " ) def get_engine ():         connection_string = (     'DRIVER={ODBC Driver 17 for SQL Server};'     f 'SERVER= { os . environ [ "DB_SERVER" ] } ;'     f 'DATABASE= { os . environ [ "DB_SCHEMA" ] } ;'     f 'UID= { os . environ [ "DB_USER" ] } ;'     f 'PWD= { os . environ [ "DB_PWD" ] } ;'     'Trusted_Connection=no;'     )     connection_url = sqlalchemy . engine . URL . create (         "mssql+pyod...

 from azure.core.credentials import AzureKeyCredential from azure.ai.documentintelligence import DocumentIntelligenceClient from azure.ai.documentintelligence.models import AnalyzeDocumentRequest from azure.storage.blob import BlobServiceClient, BlobClient, ContainerClient from warnings import filterwarnings import pyodbc import sqlalchemy from sqlalchemy import create_engine, text import json from azure.storage.blob import BlobServiceClient import pandas as pd import os from IPython.display import display from constants import STORED_PROCEDURES from connection import get_engine,get_connection_details,var_blob_connection_string,var_container_name,var_subfolder_path,var_endpoint,var_key,var_formUrl #from connection import get_engine,get_connection_details def fn_extract_document_data(Asset_Fund_Val_Doc_Map_Id,Asset_Valuation_Id):     filterwarnings("ignore", category=UserWarning, message='.*pandas only supports SQLAlchemy connectable.*')     engine = get_engine()...

 Connection.py import os import sqlalchemy import pyodbc def get_engine ():         connection_string = (     'DRIVER={ODBC Driver 17 for SQL Server};'     f 'SERVER= { os.environ[ "DB_SERVER" ] } ;'     f 'DATABASE= { os.environ[ "DB_SCHEMA" ] } ;'     f 'UID= { os.environ[ "DB_USER" ] } ;'     f 'PWD= { os.environ[ "DB_PWD" ] } ;'     'Trusted_Connection=no;'     )     connection_url = sqlalchemy.engine.URL.create(         "mssql+pyodbc" ,         query = dict ( odbc_connect = connection_string)     )     return sqlalchemy.create_engine(connection_url, fast_executemany = True ) def get_connection_details ():     conn = pyodbc.connect(         'DRIVER={ODBC Driver 17 for SQL Server}; \             SERVER= %s ; \             ...