o ee@sdZddlZddlZddlZddlmZddlmZddlm Z ddl m Z ddl m Z ddl m Z dd l mZdd l mZdd lmZdd lmZdd lmZddlmZeeZGdddeZdS)z0 This module provides a client class for Media. N) BceBaseClient) bce_v1_signer) BceResponse)bce_http_client)handler)http_content_types) http_headers) http_methods)BceClientError)BceServerError) media_handler)requiredc@seZdZdZdZdSddZeeefd    dTddZ eeefe e d dSd d Z eeefd dSd dZ eeefd dSddZ eeefeefddSddZdSddZeeefeefeefd   dUddZeeefee fd dSddZeeefddSddZeeefddSdd ZeeefddSd!d"ZdSd#d$Zeeefeefd%          dVd&d'Zeeefee fd( dSd)d*Zeeefd+dSd,d-Zeeefd+dSd.d/Zeeefd+dSd0d1Zeeefe d2dUd3d4Zeeefd dSd5d6Zeeefd    dTd7d8Zeeefeefeed9     dWd:d;Z eeefd<dSd=d>Z!dSd?d@Z"eeefd<dSdAdBZ#dSdCdDZ$eeefeefdE dSdFdGZ%eeefdHdSdIdJZ&eeefdHdSdKdLZ'dMdNZ(e)dOdPZ*   dWdQdRZ+dS)X MediaClientz sdk client z/v3NcCst||dSN)r__init__selfconfigrTD:\Projects\ConvertPro\env\Lib\site-packages\baidubce/services/media/media_client.pyr,szMediaClient.__init__) pipeline_namecC\|dkrtdd|i}|dur||d<|dur||d<|dur$||d<|jtjd||d S) a List jobs by pipelineName and jobStatus :param pipelineName: The pipeline name :type pipelineName: string or unicode :param job_status: The job status, will not filter if None :type job_status: string or unicode :param begin: The createTime should be later than or equals with begin, will not check if None :type begin: string or unicode :param end: The createTime should be earlier than or equals with end, will not check if None :type end: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse #pipeline_name can't be empty string pipelineNameN jobStatusbeginend/job/transcodingparamsrr _send_requestr GETrrZ job_statusrrrZ my_paramsrrr list_jobs/s zMediaClient.list_jobs)rsourcetargetc Cs<|dkrtd|jtjdt|||dtjtj i|dS)a} Create a job :param pipelineName: The pipeline name :type pipelineName: string or unicode :param source: source :type source: array :param target: source :type target: array :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rrr)rr&r'bodyheadersr r r"r POSTjsondumpsr CONTENT_TYPErJSON)rrr&r'rrrr create_jobWs zMediaClient.create_job)job_idcC&|dkrtd|jtjd||dS)a Get the specific job information :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rjob_id can't be empty stringz/job/transcoding/rr!rr2rrrrget_jobss zMediaClient.get_jobcCs*|dkrtd|jtjd|tj|dS)ad Get transcoding job encryption key :param job_id: The job Id want to query transcoding encryption key. :type job_id: string :param config: None :type config: BceClientConfiguration :returns: Response Object contains transcoding encryption Aes key. :rtype: baidubce.bce_response.BceResponse rr4z/transcoding/key/) body_parserr)r r"r r#r Zparse_secret_key_responser6rrrget_transcoding_encryption_keys z*MediaClient.get_transcoding_encryption_keybucketkeycCs:|dkrtd|dkrtd|jtjd||d|dS)a$ Get the media info of media information :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rbucket can't be empty stringkey can't be empty stringz /mediainfor:rr!)rr;r<rrrrget_mediainfo_of_files z!MediaClient.get_mediainfo_of_filecC|jtjd|dS)a  List pipelines :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse /pipeliner5r"r r#rrrrlist_pipelines zMediaClient.list_pipelines)r source_bucket target_bucketcCsi}|dur ||d<nd|d<|dur||d<|dkrtd|dkr'td|dkr/td||d<||d <||d <|jtjd t|tjtj i|d S) a Create a pipeline :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse N descriptionrrrz#source_bucket can't be empty stringz#target_bucket can't be empty stringrZ sourceBucketZ targetBucketrAr(r+)rrrErFrGZpipeline_configr body_contentrrrcreate_pipelines,  zMediaClient.create_pipeline)rpipelinecC0|jtjd|tj|dddtjtji|dS)a] Update a pipeline :param pipeline_name: the preset name :type pipeline_name: string :param pipeline: the update body :type pipeline: Object :returns: :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse /pipeline/cS|jSr__dict__orrrz-MediaClient.update_pipeline..defaultr( r"r PUTr-r.rr/rr0)rrrJrrrrupdate_pipeline zMediaClient.update_pipeline)Z pipelien_namecC*|dkrtd|jtjd||tjdS)aV Get the specific pipeline information without converting camel key to a "pythonic" name :param pipeline_name: The pipeline name :type pipeline_name: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rrrLrr8r r"r r#r parse_jsonrrrrrrget_pipeline_for_update  z#MediaClient.get_pipeline_for_updatecCr3)a" Get the specific pipeline information :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rrrLr5r!r^rrr get_pipeline zMediaClient.get_pipelinecCr3)a Delete the specific pipeline :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rrrLr5r r"r DELETEr^rrrdelete_pipeline'rbzMediaClient.delete_pipelinecCr@)z List presets :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse /presetr5rBrrrr list_presets7 zMediaClient.list_presets) preset_name containerc Cst} |dkr td|dkrtd|| d<|| d<|dur$d| d<n|| d<|dur0|| d<|dur8|| d <|dur@|| d <|durH|| d <|durP|| d <| durX| | d <| dur`| | d<| durh| | d<|jtjdt| tjt j i| dS)z Create a preset :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse r!preset_name can't be empty stringzcontainer can't be empty stringZ presetNamerjNrGtransmuxclipaudiovideo encryptionZ watermarkIdZextraCfgZtransCfgrfr() dictr r"r r,r-r.rr/rr0)rrirjrlrGrmrnrorp watermark_idZ extra_configZ trans_configrrHrrr create_presetBsB  zMediaClient.create_preset)ripresetcCrK)aS Update a preset :param preset_name: the preset name :type preset_name: string :param preset: the update body :type preset: Object :returns: :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse /preset/cSrMrrNrPrrrrRrSz+MediaClient.update_preset..rTr(rV)rrirtrrrr update_preset|rYzMediaClient.update_preset)ricCr3)a  Get the specific preset information :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rrkrur5r!rrirrrr get_presetrbzMediaClient.get_presetcCrZ)aN Get the specific preset information without converting camel key to a "pythonic" name :param preset_name: The preset name :type preset_name: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rrkrur[r\rwrrrget_preset_for_updater`z!MediaClient.get_preset_for_updatecCr3)a  Delete a preset :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rrkrur5rcrwrrr delete_presetrbzMediaClient.delete_preset)rr&cCshi}|dkr td|dur||d<|dur||d<||d<||d<|jtjdt|tjtj i|d S) a Create thumbnail job :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rrNr'capturerr&/job/thumbnailr(r+)rrr&r'r{rrHrrrcreate_thumbnail_jobs   z MediaClient.create_thumbnail_jobcCr3)a Get thumbnail job :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rr4z/job/thumbnail/r5r!r6rrrget_thumbnail_jobrbzMediaClient.get_thumbnail_jobcCr) a List thumbnail jobs by pipelineName :param pipelineName: The pipeline name :type pipelineName: string or unicode :param job_status: The thumbnail job status, will not filter if None :type job_status: string or unicode :param begin: The createTime should be later than or equals with begin, will not check if None :type begin: string or unicode :param end: The createTime should be earlier than or equals with end, will not check if None :type end: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rrrNrrrr|rr!r$rrrlist_thumbnail_jobs_by_pipelines z+MediaClient.list_thumbnail_jobs_by_pipeline)r;r<vertical_offset_in_pixelhori_offset_in_pixelc Cs|dkrtd|dkrtdi}||d<||d<|dur"||d<|dur*||d<|dur2||d <|dur:||d <|jtjd t|tjtj i|d S) a  Create watermark :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rr=r>r;r<NZverticalAlignmentZhorizontalAlignmentZverticalOffsetInPixelZhorizontalOffsetInPixel /watermarkr(r+) rr;r<Zvertical_alignmentZhorizontal_alignmentrrrrHrrrcreate_watermarks, zMediaClient.create_watermark)rrcCr3)a# Get the specific watermark information :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse r"watermark_id can't be empty string /watermark/r5r!rrrrrrr get_watermarkJrbzMediaClient.get_watermarkcCr@)a  List watermarks :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rr5rBrrrrlist_watermarksZrDzMediaClient.list_watermarkscCr3)a Delete the specific watermark :param pipelineName: The pipeline name :type pipelineName: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rrrr5rcrrrrdelete_watermarkgrbzMediaClient.delete_watermarkcCr@)z List notifications :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse /notificationr5rBrrrrlist_notificationswrhzMediaClient.list_notificationsnameendpointcCsN|dkrtd|dkrtd||d}|jtjdt|tjtj i|dS)aV Create a notification :param name: The notification name :type name: string or unicode :param endpoint: The endpoint :type endpoint: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rname can't be empty stringzendpoint can't be empty stringrrr(r+)rrrrrHrrrcreate_notifications zMediaClient.create_notification)rcCr3)a Get the specific notification information :param name: The notification name :type name: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rr/notification/r5r!rrrrrrget_notificationrbzMediaClient.get_notificationcCr3)a Delete the specific notification :param name: The notification name :type name: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse rrrr5rcrrrrdelete_notificationrbzMediaClient.delete_notificationcCs.d}|dur t||}|dur|St|j|Sr)getattrr)rrattrresultrrr_get_config_parameters   z!MediaClient._get_config_parametercCs(|dur|jSt|j}|||Sr)rcopyZmerge_non_none_values)rrZ new_configrrr _merge_configs   zMediaClient._merge_configc CsJ|||}|dur tj}tj|}t|tjtj |g|t ||||Sr) rrr]rprefixr send_requestrsignZ parse_errorstrencode) rZ http_methodpathr)r*r rr8realpathrrrr"s  zMediaClient._send_requestr)NNNN)NNN) NNNNNNNNNN)NNNNN),__name__ __module__ __qualname____doc__rrr bytesrr%rqr1r7r9r?rCrIrrXr_rarergrsrvrxryrzr}r~rintrrrrrrrrr staticmethodrr"rrrrr%s   '          )         9           (  )           r)rrr-loggingZbaidubce.bce_base_clientrZ baidubce.authrZbaidubce.bce_responserZ baidubce.httprrrrr Zbaidubce.exceptionr r Zbaidubce.services.mediar Zbaidubce.utilsr getLoggerrZ_loggerrrrrrs$