def getMongoDB(**context):
    token = context.get("ti").xcom_pull(key="token")
    response = requests.get(
    url=f"{dRoW_api_end_url}/api/module/document-export/airflow/workflow/6780da3a19a6ea5c197f5e8a?export_type=0",
    headers={
            "x-access-token": f"Bearer {token}",
            "ICWPxAccessKey": "5WSD21ICWP_[1AG:4UdI){n=b~"
        }
    )

    RISC_Data = json.loads(response.text)
    conn_string = getdrowPSQLConnectionString()
    db = create_engine(conn_string)
    conn = db.connect()

    with conn as conn:
        df = pd.DataFrame()
        for x in RISC_Data:
            df_nested_list = json_normalize(x['data'])

            for sequence in df_nested_list['ITP Sequence (Hold Points Only)'][0]:
                df2 = pd.DataFrame([sequence])
                df2['Type'] = df_nested_list['Type']
                df2['Method Statement Submission No.'] = df_nested_list['Method Statement Submission No.']
                df2['ITP Type Identifier'] = df_nested_list['ITP Type Identifier']
                df2['Labour Type'] = df_nested_list['Labour Type']
                df2['Description'] = df_nested_list['Description']

                df = df.append(df2)

        df.columns = df.columns.str.replace(' ', '_').str.replace('.', '', regex=False).str.replace('(', '_', regex=False).str.replace(')', '', regex=False).str.replace('%', 'percent', regex=False).str.replace('/', '_', regex=False)
        df.to_sql('itp_hy202308', con=conn, if_exists='replace', index= False)
        conn.close()