| j' DSSKrSSKrSSKJr SSKJr SSKJr SSKJrJ r SSK J r SSK r SSK Jr SSKJr SS KJr SS KJrJr SS KJr SS KJr "S S\5rS\4SjrSS\S\S\S\4SjjrSS\S\S\S\4SjjrSS\S\4Sjjr SS\S\S\S\4Sjjr!g)N)datetime) HTTPStatus)mktime) unquote_plusurlparse)format_date_time)DashScopeAPIResponse)GetMixin)FILE_PATH_SCHEMA) InvalidInputUploadFileException)logger)get_user_agentc ^\rSrSrSr\S\R4Sj5r\S S\ S\ S\ S\ 4S jj5r \SS\ S\ S \ 4U4S jjj5r S rU=r$)OssUtilsuploadsresponsecSURRSS5;aUR5nU$URR S5nU$)Napplication/jsonz content-typezutf-8)headersgetjsoncontentdecode)clsrmessages ڧC:\Users\johnn\AppData\Local\Packages\PythonSoftwareFoundation.Python.3.13_qbz5n2kfra8p0\LocalCache\local-packages\Python313\site-packages\dashscope/utils/oss_utils.py_decode_response_errorOssUtils._decode_response_errorsL !1!1!5!5nb!I ImmoG&&--g6Gmodel file_pathapi_keyupload_certificatec UceUR"S#UUS.UD6nUR[R:wa%[ SUR SUR 35eURnOUn0nS[50nSUS'[[[R"5R555US'0nUS US 'US US 'US US 'USS-[RR!U5-US'USUS'USUS'SUS'["R$"U5S=(d SUS'USn ['US5n SU 0n [(R*"5n U R-U U UUSS9n U R[R:XaSUS-U4sSSS5 sSSS5 $S US!UR/U S"93n[0R2"U5 [ U5e!,(df  O=fSSS5 g!,(df  g=f)$aUpload file for model fine-tune or other tasks. Args: file_path (str): The local file name to upload. purpose (str): The purpose of the file[fine-tune|inference] description (str, optional): The file description message. api_key (str, optional): The api key. Defaults to None. upload_certificate (dict, optional): Reusable upload certificate. Defaults to None. Returns: tuple: (file_url, upload_certificate) where file_url is the OSS URL and upload_certificate is the certificate used N)r#r%z%Get upload certificate failed, code: z , message: z user-agentrAcceptDateoss_access_key_idOSSAccessKeyId signature Signaturepolicy upload_dir/keyx_oss_object_aclzx-oss-object-aclx_oss_forbid_overwritezx-oss-forbid-overwrite200success_action_statusrzapplication/octet-streamzx-oss-content-type upload_hostrbfilei)filesdatartimeoutoss://Uploading file: z to oss failed, error: )r)get_upload_certificate status_coderOKr coderoutputrrrrnow timetupleospathbasename mimetypes guess_typeopenrequestsSessionpostr rerror)rr#r$r%r&kwargs upload_infor form_dataurlfr9sessionrmsgs ruploadOssUtils.upload!s].  %44K &&*--7);"''( K4G4G3HJ&,,K,K!12.*6(,,.2J2J2L+MN &12E&F "#!,[!9 +)(3 (  % +bgg.>.>y.I I %)44F(G $%.9 $/ *+.3 )*   +A . L2L &'-( )T "aQKE!!#w"<<"# ('':==8#i&66 C$## "+9+6"55x5HIK LL%-c22#$### " "s*G? ;G$ G?.6G$$ G2 .G?? H returnc <>SS0nXS'[TU]"SU4SU0UD6$)zGet a oss upload certificate. Args: api_key (str, optional): The api key. Defaults to None. Returns: DashScopeAPIResponse: The job info action getPolicyr#Nparams)superr)rr#r%rPr] __class__s rr?OssUtils.get_upload_certificateos1K(ww{4BB6BBr"r>)NNN)__name__ __module__ __qualname____firstlineno__SUB_PATH classmethodrLResponser strdictrWr r?__static_attributes__ __classcell__)r_s@rrrsHh.?.? #' K3K3K3 K3 ! K3K3ZCCC  CCr"rfile_uricN[U5nUR(a#UR[UR5-nO[UR5nUR S5(a[ U5S:aUSS:XaUSSn[ RRU5$)Nr0:)rnetlocrrG startswithlenrF expanduser)rm parse_resultr$s r_resolve_file_uri_pathrwsH%L '',|7H7H*II  !2!23  S!!  NQ  aLC abM 77  i ((r"r# upload_pathr%r&c UR[5(aj[U5n[RR U5(a,[ RUUUUS9upVUc[SUS35eU$[SUS35eg)Nr#r$r%r&r= failed The file:  is not exists!) rsr rwrFrGexistsrrWr r )r#rxr%r&r$file_url_s r upload_filers .//*;7 77>>) $ $"//##5 *KH )&{m7;OI;oFG G r"rcXUR[5(al[U5n[RR U5(a.[ RUUUUS9upVUc[SUS35eSXV4$[SUS35eURS5(aSX4$URS5(dq[RRU5n[RR U5(a.[ RUUUUS9upVUc[SUS35eSXV4$S X4$) aCheck the content is local file path, upload and return the url Args: model (str): Which model to upload. content (str): The content. api_key (_type_): The api key. upload_certificate (dict, optional): Reusable upload certificate. Defaults to None. Raises: UploadFileException: Upload failed. InvalidInput: The input is invalid Returns: tuple: (is_upload, file_url_or_content, upload_certificate) where is_upload indicates if file was uploaded, file_url_or_content is the result URL or original content, and upload_certificate is the certificate (newly obtained or passed in) rzr=r{Tr|r}r<httpF) rsr rwrFrGisfilerrWr r ru)r#rr%r&r$rcerts rcheck_and_upload_localrsD2*++*73 77>>) $ $%__##5 -NH )&wiw7' 'Z {/BCC(##W00   f % %''$$W- 77>>' " "%__!#5 -NH )&wiw7' ' ' --r"elemcSnUnUR5Hlupg[U[5nU(aUOU/n US;a5[U 5H&up[ UUUU5un n nU (dM XU 'SnM( U(aU OU SX'Mn XE4$)aCheck and upload files in element. Args: model: Model name elem: Element dict containing file references api_key: API key upload_certificate: Optional upload certificate to reuse Returns: tuple: (has_upload, upload_certificate) where has_upload is bool indicating if any file was uploaded, and upload_certificate is the certificate (newly obtained or passed in) F)imagevideoaudiotextTr)items isinstancelist enumerater) r#rr%r& has_uploadobtained_certificater1ris_listcontentsi is_uploadrs rcheck_and_uploadrs&J- Wd+%7G9 5 5'1  +(  (9"*QK!%J2!(HXa[ )%,  ++r"c([UUUU5upEXE4$)aPreprocess message element and upload files if needed. Args: model: Model name elem: Element dict containing file references api_key: API key upload_certificate: Optional upload certificate to reuse Returns: tuple: (is_upload, upload_certificate) where is_upload is bool indicating if any file was uploaded, and upload_certificate is the certificate (newly obtained or passed in) )r)r#rr%r&rrs rpreprocess_message_elementrs&&'   OI ?r"ra)"rIrFrrrtimer urllib.parserrwsgiref.handlersrrL)dashscope.api_entities.dashscope_responser dashscope.client.base_apir dashscope.common.constantsr dashscope.common.errorr r dashscope.common.loggingrdashscope.common.utilsrrrirwrjrrrrr>r"rrs /-J.7D+1kCxkC\)S)* $   : $ 8. 8. 8.8. 8.~ $ ,, ,, ,,f $    r"