
    ii                     >    d dl Z d dlZd dlZd dlmZmZ d Zd Zd Zy)    N)urlparseparse_qsc                    	 t        |d      5 }dddd}t        j                  | ||d      }|j                  dk\  r1|j                  d	k  r"t	        j
                  d
|         	 d d d        yt	        j                  d|j                   d|j                          	 d d d        y# 1 sw Y   y xY w# t        $ r+}t	        j                  dt        |              Y d }~yd }~ww xY w)Nrb	BlockBlobz	audio/wav
2021-06-08)zx-ms-blob-typezContent-Typex-ms-versionF)headersdataverify   i,  u   ✅ Upload successful: TzUpload failed with status : zAzure upload error: )
openrequestsputstatus_codelogginginfoerrortext	Exceptionstr)sas_url	file_pathfr
   responsees         ;C:\Users\pc\OneDrive\Desktop\rabbitmqsarvam\azure_upload.pyupload_to_azure_blobr      s    )T"a"- + ,G
  ||GW1USH##s*x/C/Cc/I6wi@A #"  :8;O;O:PPRS[S`S`Rabc #""  ,SVH56sA   B3 AB'%B3 .0B'B3 'B0,B3 0B3 3	C'<!C""C'c                    	 t        |       }|j                   d|j                   |j                   }t	        |j
                        }|}|rNg }|j                         D ]"  \  }}|D ]  }|j                  | d|         $ |ddj                  |      z   z  }ddi}	t        j                  ||	d      }
|
j                  d	v rt        j                  d
|        yt        j                  d|
j                   d|
j                          y# t         $ r+}t        j"                  dt%        |              Y d}~yd}~ww xY w)z1Delete file from Azure Blob Storage using SAS URLz://=?&r	   r   F)r
   r   )r         u%   ✅ Azure blob deleted successfully: Tu.   ⚠️ Azure blob deletion failed with status r   u   ❌ Azure blob deletion error: N)r   schemenetlocpathr   queryitemsappendjoinr   deleter   r   r   warningr   r   r   r   )r   
parsed_urlbase_urlquery_params
delete_urlparam_pairskeyvaluesvaluer
   r   r   s               r   delete_from_azure_blobr7   &   sL   !g&
 ''(J,=,=+>z>OP  
 0 01 
K+113V#E&&#aw'78 $  4 # 555J L
 ??:wuM?2LL@
KLOOLXMaMaLbbdemererdstu 7Ax@As   CD /D 	E!D==Ec                     	 t        |       rt        j                  d       yt        j                  d       y# t        $ r+}t        j
                  dt        |              Y d}~yd}~ww xY w)z'Clean up Azure storage after processingu$   🧹 Azure storage cleanup completedu6   ⚠️ Azure storage cleanup failed, but continuing...u!   ❌ Azure storage cleanup error: N)r7   r   r   r.   r   r   r   )r   r   s     r   cleanup_azure_storager9   K   sW    D!'*LL?@OOTU D9#a&BCCDs    9 9 	A-!A((A-)	r   r   osurllib.parser   r   r   r7   r9        r   <module>r>      s$      	 +(#JDr=   