@@ -86,8 +86,6 @@ <h1>Source code for cellpack.autopack</h1><div class="highlight"><pre>
86
86
< span class ="kn "> from</ span > < span class ="nn "> collections</ span > < span class ="kn "> import</ span > < span class ="n "> OrderedDict</ span >
87
87
< span class ="kn "> from</ span > < span class ="nn "> pathlib</ span > < span class ="kn "> import</ span > < span class ="n "> Path</ span >
88
88
89
- < span class ="kn "> import</ span > < span class ="nn "> boto3</ span >
90
- < span class ="kn "> import</ span > < span class ="nn "> botocore</ span >
91
89
92
90
< span class ="kn "> from</ span > < span class ="nn "> cellpack.autopack.DBRecipeHandler</ span > < span class ="kn "> import</ span > < span class ="n "> DBRecipeLoader</ span >
93
91
< span class ="kn "> from</ span > < span class ="nn "> cellpack.autopack.interface_objects.database_ids</ span > < span class ="kn "> import</ span > < span class ="n "> DATABASE_IDS</ span >
@@ -310,23 +308,6 @@ <h1>Source code for cellpack.autopack</h1><div class="highlight"><pre>
310
308
311
309
312
310
313
- < div class ="viewcode-block " id ="download_file_from_s3 ">
314
- < a class ="viewcode-back " href ="../../cellpack.autopack.html#cellpack.autopack.download_file_from_s3 "> [docs]</ a >
315
- < span class ="k "> def</ span > < span class ="nf "> download_file_from_s3</ span > < span class ="p "> (</ span > < span class ="n "> s3_uri</ span > < span class ="p "> ,</ span > < span class ="n "> local_file_path</ span > < span class ="p "> ):</ span >
316
- < span class ="n "> s3_client</ span > < span class ="o "> =</ span > < span class ="n "> boto3</ span > < span class ="o "> .</ span > < span class ="n "> client</ span > < span class ="p "> (</ span > < span class ="s2 "> "s3"</ span > < span class ="p "> )</ span >
317
- < span class ="n "> bucket_name</ span > < span class ="p "> ,</ span > < span class ="n "> key</ span > < span class ="o "> =</ span > < span class ="n "> parse_s3_uri</ span > < span class ="p "> (</ span > < span class ="n "> s3_uri</ span > < span class ="p "> )</ span >
318
-
319
- < span class ="k "> try</ span > < span class ="p "> :</ span >
320
- < span class ="n "> s3_client</ span > < span class ="o "> .</ span > < span class ="n "> download_file</ span > < span class ="p "> (</ span > < span class ="n "> bucket_name</ span > < span class ="p "> ,</ span > < span class ="n "> key</ span > < span class ="p "> ,</ span > < span class ="n "> local_file_path</ span > < span class ="p "> )</ span >
321
- < span class ="nb "> print</ span > < span class ="p "> (</ span > < span class ="s2 "> "File downloaded successfully."</ span > < span class ="p "> )</ span >
322
- < span class ="k "> except</ span > < span class ="n "> botocore</ span > < span class ="o "> .</ span > < span class ="n "> exceptions</ span > < span class ="o "> .</ span > < span class ="n "> ClientError</ span > < span class ="k "> as</ span > < span class ="n "> e</ span > < span class ="p "> :</ span >
323
- < span class ="k "> if</ span > < span class ="n "> e</ span > < span class ="o "> .</ span > < span class ="n "> response</ span > < span class ="p "> [</ span > < span class ="s2 "> "Error"</ span > < span class ="p "> ][</ span > < span class ="s2 "> "Code"</ span > < span class ="p "> ]</ span > < span class ="o "> ==</ span > < span class ="s2 "> "404"</ span > < span class ="p "> :</ span >
324
- < span class ="nb "> print</ span > < span class ="p "> (</ span > < span class ="s2 "> "The object does not exist."</ span > < span class ="p "> )</ span >
325
- < span class ="k "> else</ span > < span class ="p "> :</ span >
326
- < span class ="nb "> print</ span > < span class ="p "> (</ span > < span class ="s2 "> "An error occurred while downloading the file."</ span > < span class ="p "> )</ span > </ div >
327
-
328
-
329
-
330
311
< div class ="viewcode-block " id ="parse_s3_uri ">
331
312
< a class ="viewcode-back " href ="../../cellpack.autopack.html#cellpack.autopack.parse_s3_uri "> [docs]</ a >
332
313
< span class ="k "> def</ span > < span class ="nf "> parse_s3_uri</ span > < span class ="p "> (</ span > < span class ="n "> s3_uri</ span > < span class ="p "> ):</ span >
@@ -341,25 +322,23 @@ <h1>Source code for cellpack.autopack</h1><div class="highlight"><pre>
341
322
342
323
343
324
325
+ < div class ="viewcode-block " id ="is_s3_url ">
326
+ < a class ="viewcode-back " href ="../../cellpack.autopack.html#cellpack.autopack.is_s3_url "> [docs]</ a >
327
+ < span class ="k "> def</ span > < span class ="nf "> is_s3_url</ span > < span class ="p "> (</ span > < span class ="n "> file_path</ span > < span class ="p "> ):</ span >
328
+ < span class ="k "> return</ span > < span class ="n "> file_path</ span > < span class ="o "> .</ span > < span class ="n "> find</ span > < span class ="p "> (</ span > < span class ="s2 "> "s3://"</ span > < span class ="p "> )</ span > < span class ="o "> !=</ span > < span class ="o "> -</ span > < span class ="mi "> 1</ span > </ div >
329
+
330
+
331
+
344
332
< div class ="viewcode-block " id ="download_file ">
345
333
< a class ="viewcode-back " href ="../../cellpack.autopack.html#cellpack.autopack.download_file "> [docs]</ a >
346
- < span class ="k "> def</ span > < span class ="nf "> download_file</ span > < span class ="p "> (</ span > < span class ="n "> url</ span > < span class ="p "> ,</ span > < span class ="n "> local_file_path</ span > < span class ="p "> ,</ span > < span class ="n "> reporthook</ span > < span class ="p "> ):</ span >
334
+ < span class ="k "> def</ span > < span class ="nf "> download_file</ span > < span class ="p "> (</ span > < span class ="n "> url</ span > < span class ="p "> ,</ span > < span class ="n "> local_file_path</ span > < span class ="p "> ,</ span > < span class ="n "> reporthook</ span > < span class ="p "> , </ span > < span class =" n " > database_name </ span > < span class =" o " > = </ span > < span class =" s2 " > "aws" </ span > < span class =" p " > ):</ span >
347
335
< span class ="k "> if</ span > < span class ="n "> is_s3_url</ span > < span class ="p "> (</ span > < span class ="n "> url</ span > < span class ="p "> ):</ span >
348
- < span class ="c1 "> # download from s3</ span >
349
- < span class ="c1 "> # bucket_name, folder, key = parse_s3_uri(url)</ span >
350
- < span class ="c1 "> # s3_handler = DATABASE_IDS.handlers().get(DATABASE_IDS.AWS)</ span >
351
- < span class ="c1 "> # s3_handler = s3_handler(bucket_name, folder)</ span >
352
- < span class ="n "> s3_client</ span > < span class ="o "> =</ span > < span class ="n "> boto3</ span > < span class ="o "> .</ span > < span class ="n "> client</ span > < span class ="p "> (</ span > < span class ="s2 "> "s3"</ span > < span class ="p "> )</ span >
336
+ < span class ="n "> db</ span > < span class ="o "> =</ span > < span class ="n "> DATABASE_IDS</ span > < span class ="o "> .</ span > < span class ="n "> handlers</ span > < span class ="p "> ()</ span > < span class ="o "> .</ span > < span class ="n "> get</ span > < span class ="p "> (</ span > < span class ="n "> database_name</ span > < span class ="p "> )</ span >
353
337
< span class ="n "> bucket_name</ span > < span class ="p "> ,</ span > < span class ="n "> folder</ span > < span class ="p "> ,</ span > < span class ="n "> key</ span > < span class ="o "> =</ span > < span class ="n "> parse_s3_uri</ span > < span class ="p "> (</ span > < span class ="n "> url</ span > < span class ="p "> )</ span >
354
- < span class ="k "> try</ span > < span class ="p "> :</ span >
355
- < span class ="n "> s3_client</ span > < span class ="o "> .</ span > < span class ="n "> download_file</ span > < span class ="p "> (</ span > < span class ="n "> bucket_name</ span > < span class ="p "> ,</ span > < span class ="sa "> f</ span > < span class ="s2 "> "</ span > < span class ="si "> {</ span > < span class ="n "> folder</ span > < span class ="si "> }</ span > < span class ="s2 "> /</ span > < span class ="si "> {</ span > < span class ="n "> key</ span > < span class ="si "> }</ span > < span class ="s2 "> "</ span > < span class ="p "> ,</ span > < span class ="n "> local_file_path</ span > < span class ="p "> )</ span >
356
- < span class ="nb "> print</ span > < span class ="p "> (</ span > < span class ="s2 "> "File downloaded successfully."</ span > < span class ="p "> )</ span >
357
- < span class ="k "> except</ span > < span class ="n "> botocore</ span > < span class ="o "> .</ span > < span class ="n "> exceptions</ span > < span class ="o "> .</ span > < span class ="n "> ClientError</ span > < span class ="k "> as</ span > < span class ="n "> e</ span > < span class ="p "> :</ span >
358
- < span class ="k "> if</ span > < span class ="n "> e</ span > < span class ="o "> .</ span > < span class ="n "> response</ span > < span class ="p "> [</ span > < span class ="s2 "> "Error"</ span > < span class ="p "> ][</ span > < span class ="s2 "> "Code"</ span > < span class ="p "> ]</ span > < span class ="o "> ==</ span > < span class ="s2 "> "404"</ span > < span class ="p "> :</ span >
359
- < span class ="nb "> print</ span > < span class ="p "> (</ span > < span class ="s2 "> "The object does not exist."</ span > < span class ="p "> )</ span >
360
- < span class ="k "> else</ span > < span class ="p "> :</ span >
361
- < span class ="nb "> print</ span > < span class ="p "> (</ span > < span class ="s2 "> "An error occurred while downloading the file."</ span > < span class ="p "> )</ span >
362
-
338
+ < span class ="n "> initialize_db</ span > < span class ="o "> =</ span > < span class ="n "> db</ span > < span class ="p "> (</ span >
339
+ < span class ="n "> bucket_name</ span > < span class ="o "> =</ span > < span class ="n "> bucket_name</ span > < span class ="p "> ,</ span > < span class ="n "> sub_folder_name</ span > < span class ="o "> =</ span > < span class ="n "> folder</ span > < span class ="p "> ,</ span > < span class ="n "> region_name</ span > < span class ="o "> =</ span > < span class ="s2 "> "us-west-2"</ span >
340
+ < span class ="p "> )</ span >
341
+ < span class ="n "> initialize_db</ span > < span class ="o "> .</ span > < span class ="n "> download_file</ span > < span class ="p "> (</ span > < span class ="sa "> f</ span > < span class ="s2 "> "</ span > < span class ="si "> {</ span > < span class ="n "> folder</ span > < span class ="si "> }</ span > < span class ="s2 "> /</ span > < span class ="si "> {</ span > < span class ="n "> key</ span > < span class ="si "> }</ span > < span class ="s2 "> "</ span > < span class ="p "> ,</ span > < span class ="n "> local_file_path</ span > < span class ="p "> )</ span >
363
342
< span class ="k "> elif</ span > < span class ="n "> url_exists</ span > < span class ="p "> (</ span > < span class ="n "> url</ span > < span class ="p "> ):</ span >
364
343
< span class ="k "> try</ span > < span class ="p "> :</ span >
365
344
< span class ="n "> urllib</ span > < span class ="o "> .</ span > < span class ="n "> urlretrieve</ span > < span class ="p "> (</ span > < span class ="n "> url</ span > < span class ="p "> ,</ span > < span class ="n "> local_file_path</ span > < span class ="p "> ,</ span > < span class ="n "> reporthook</ span > < span class ="o "> =</ span > < span class ="n "> reporthook</ span > < span class ="p "> )</ span >
@@ -380,13 +359,6 @@ <h1>Source code for cellpack.autopack</h1><div class="highlight"><pre>
380
359
381
360
382
361
383
- < div class ="viewcode-block " id ="is_s3_url ">
384
- < a class ="viewcode-back " href ="../../cellpack.autopack.html#cellpack.autopack.is_s3_url "> [docs]</ a >
385
- < span class ="k "> def</ span > < span class ="nf "> is_s3_url</ span > < span class ="p "> (</ span > < span class ="n "> file_path</ span > < span class ="p "> ):</ span >
386
- < span class ="k "> return</ span > < span class ="n "> file_path</ span > < span class ="o "> .</ span > < span class ="n "> find</ span > < span class ="p "> (</ span > < span class ="s2 "> "s3://"</ span > < span class ="p "> )</ span > < span class ="o "> !=</ span > < span class ="o "> -</ span > < span class ="mi "> 1</ span > </ div >
387
-
388
-
389
-
390
362
< div class ="viewcode-block " id ="is_remote_path ">
391
363
< a class ="viewcode-back " href ="../../cellpack.autopack.html#cellpack.autopack.is_remote_path "> [docs]</ a >
392
364
< span class ="k "> def</ span > < span class ="nf "> is_remote_path</ span > < span class ="p "> (</ span > < span class ="n "> file_path</ span > < span class ="p "> ):</ span >
0 commit comments