@@ -89,23 +89,21 @@ async def blob_to_dzi_eventgrid_trigger(event: func.EventGridEvent):
8989 # Upload DZI files and all subdirectory files to the destination container using AzCopy
9090 def upload_with_azcopy (local_dir ):
9191 dest_url = os .environ .get ('DZI_UPLOAD_DEST_URL' )
92- for item in os .listdir (local_dir ):
93- item_path = os .path .join (local_dir , item )
94- cmd = [
95- "azcopy" , "copy" ,
96- os .path .join (item_path , "*" ) if os .path .isdir (item_path ) else item_path ,
97- dest_url ,
98- "--recursive=true"
99- ]
100- logger .info (f"AzCopy command: azcopy copy { cmd [2 ]} { dest_url } --recursive=true (using SAS token)" )
101- result = subprocess .run (cmd , capture_output = True , text = True )
102- logger .info (f"AzCopy stdout: { result .stdout } " )
103- logger .info (f"AzCopy stderr: { result .stderr } " )
104- logger .info (f"AzCopy returncode: { result .returncode } " )
105- if result .returncode == 0 :
106- logger .info (f"AzCopy upload successful for { cmd [2 ]} " )
107- else :
108- logger .error (f"AzCopy failed with exit code { result .returncode } for { cmd [2 ]} " )
92+ cmd = [
93+ "azcopy" , "copy" ,
94+ os .path .join (local_dir , "*" ),
95+ dest_url ,
96+ "--recursive=true"
97+ ]
98+ logger .info (f"AzCopy command: azcopy copy { cmd [2 ]} { dest_url } --recursive=true (using SAS token)" )
99+ result = subprocess .run (cmd , capture_output = True , text = True )
100+ logger .info (f"AzCopy stdout: { result .stdout } " )
101+ logger .info (f"AzCopy stderr: { result .stderr } " )
102+ logger .info (f"AzCopy returncode: { result .returncode } " )
103+ if result .returncode == 0 :
104+ logger .info (f"AzCopy upload successful for { cmd [2 ]} " )
105+ else :
106+ logger .error (f"AzCopy failed with exit code { result .returncode } for { cmd [2 ]} " )
109107
110108 upload_with_azcopy (dzi_output_dir )
111109
0 commit comments