dZddlmZddlmZddlmZddlZddlmZddlm Z ddlm Z dd l m Z d Z d ZGd d eZy)zUtilities for Edge ML API.)absolute_import)division)unicode_literalsN)encoding_helper) operations)util) propertiesc4tjdd|dS)z?Converts model[.tflite] style filename to model_edgetpu.tflite.z (\.tflite)?$z_edgetpu.tflitecountresubsources +lib/googlecloudsdk/api_lib/edgeml/edgeml.py_CompileDestinationrs !2F! DDc4tjdd|dS)zGConverts model[/saved_model.(pb|pbtxt)] style filename to model.tflite.z(/saved_model\.(pb|pbtxt))?$z.tfliter r rrs r_ConvertDestinationr"s /F! LLrc.eZdZdZddZdZddZddZy) EdgeMlClientzClient for Edge ML service. Attributes: client: Generated Edge ML API client. messages: Generated Edge ML API messages. Nc|xstj|_|xstj||_|jj |_tj|||_ yN) rGetClientInstanceclientGetMessagesModulemessagesprojects_models_servicerOperationsClient_operations_client)selfrrs r__init__zEdgeMlClient.__init__/sT4D224DK> 6 6v >DMKK//DM(99&(KDrcdtjjjj z}|j j |j j|j j|g|}|jj|}|jj|}tj|j jtj |}|S)aAnalyzes a machine learning model. The AnalyzeResponse will contain model's framework, and for TF models it will also contain Edge TPU compiliability and input/output tensor information. Args: source: str, GCS object URI to the model file or directory to analyze. Returns: AnalyzedResponse on the finish of analyze operation. Raises: LongrunningError: when long running operation fails. projects/ inputUris gcsSource)analyzeModelRequestproject)r VALUEScorer- GetOrFailr"EdgemlProjectsModelsAnalyzeRequestAnalyzeModelRequest GcsSourcer!Analyzer#WaitForOperationr JsonToMessageAnalyzeModelResponse MessageToJson)r$rr- analyze_req operationresultresponses rr4zEdgeMlClient.Analyze5s J--22::DDFFG--BB MM==mm---A>CCK %%k2I  $ $ 5 5i @F,, **%%f-/H Orcdtjjjj z}|s t |}|j j}|jj}|j j|j j|g}|j j|j j|}|j j|||||}|jj!|} |j"j%| } t'j(|j j*t'j,| } | |fS)aOptimizes a TFLite model for EdgeTPU. Args: source: str, GCS object URI to the model file to compile. Must be a .tflite file. destination: str, GCS URI to an output tflite object. If not provided, for source filename `model[.tflite]` this will be set to `model_edgetpu.tflite`. Returns: (CompileModelResponse, output object URI) on the finish of compilation. Raises: LongrunningError: when long running operation fails. r'r(r* outputUrigcsDestination)chipType inputConfig outputConfig)compileModelRequestr-)r r.r/r-r0rrCompileModelRequestChipTypeValueValuesEnum EDGE_TPU_V1 InputConfigr3 OutputConfigGcsDestination"EdgemlProjectsModelsCompileRequestr!Compiler#r5rr6CompileModelResponser8) r$r destinationr-compile_req_type chip_type input_config output_config compile_reqr:r;r<s rrMzEdgeMlClient.CompileRsL J--22::DDFFG '/k}}88 88DDI==,,--))VH)=-?LMM..}}33k3J/LM--BB,$&( CK %%k2I  $ $ 5 5i @F,, **%%f-/H [  rcdtjjjj z}|s t |}|j j|j j|g}|j j|j j|}|j j|j j|||}|jj|}|jj!|}t#j$|j j&t#j(|} | |fS)aConverts Tensorflow SavedModel to TFLite model. Args: source: str, GCS URI to an input SavedModel archive destination: str, GCS URI to an output tflite object. If not provided, for source filename `model[/saved_model.(pb|pbtxt)]` this will be set to `model.tflite`. Returns: (ConvertModelResponse, output object URI) on the finish of convert operation. Raises: LongrunningError: when long running operation fails. r'r(r*r>r@)rCrD)convertModelRequestr-)r r.r/r-r0rrrIr3rJrK"EdgemlProjectsModelsConvertRequestConvertModelRequestr!Convertr#r5rr6ConvertModelResponser8) r$rrOr-rRrS convert_reqr:r;r<s rrYzEdgeMlClient.Convert|s5 J--22::DDFFG '/k==,,--))VH)=-?LMM..}}33k3J/LM--BB MM==$=>BCK  %%k2I  $ $ 5 5i @F,, **%%f-/H [  r)NNr)__name__ __module__ __qualname____doc__r%r4rMrYrrrr'sL :(!T$!rr)r_ __future__rrrrapitools.base.pyrgooglecloudsdk.api_lib.edgemlrrgooglecloudsdk.corer rrobjectrr`rrrfs<!&' ,4.*E M y!6y!r