U h*@sdZddlZddlmZddlmZmZmZmZddl m Z m Z ddl m Z mZddlmZddlmZdd lmZmZmZdd lmZmZeeZGd d d eZGd ddeZGdddeZdS)z.Tools for interacting with a Power BI dataset.N) perf_counter)AnyDictOptionalTuple)AsyncCallbackManagerForToolRunCallbackManagerForToolRun)Field validator)BaseTool)_import_tiktoken)BAD_REQUEST_RESPONSEDEFAULT_FEWSHOT_EXAMPLESRETRY_RESPONSE)PowerBIDataset json_to_mdc@sFeZdZUdZdZeed<dZeed<eed<e ddZ e ed <e Z eeed <e edd Zeeefed <d Zeed<dZeed<dZeeed<GdddZedeedddZeeedddZd&eeeeedddZd'eeeeedddZeeefeeeeefd d!d"Zeee efd#d$d%Z!dS)(QueryPowerBIToolz%Tool for querying a Power BI Dataset.Z query_powerbinamea Input to this tool is a detailed question about the dataset, output is a result from the dataset. It will try to answer the question using the dataset, and if it cannot, it will ask for clarification. Example Input: "How many rows are in table1?" description llm_chainTexcludepowerbiexamples)default_factoryr session_cachemax_iterationsioutput_token_limitNtiktoken_model_namec@seZdZdZdS)zQueryPowerBITool.ConfigTN__name__ __module__ __qualname__Zarbitrary_types_allowedr$r$J/tmp/pip-unpacked-wheel-9gdii04g/langchain_community/tools/powerbi/tool.pyConfig*sr&)rreturncCs(|jjD]}|dkrtd|jjq|S)z8Make sure the LLM chain has the correct input variables.) tool_inputtablesschemasrzrLLM chain for QueryPowerBITool must have input variables ['tool_input', 'tables', 'schemas', 'examples'], found %s)promptZinput_variables ValueError)clsrvarr$r$r%"validate_llm_chain_input_variables-s z3QueryPowerBITool.validate_llm_chain_input_variables)r(r'cCs||jkrdS|j|S)zCheck if the input is present in the cache. If the value is a bad request, overwrite with the escalated version, if not present return None.N)r)selfr(r$r$r% _check_cache:s zQueryPowerBITool._check_cache)r( run_managerkwargsr'c Ks||}r td|||Sz@td||jj||j|j|j |rV| ndd}Wn@t k r}z"d||j |<|j |WYSd}~XYnX|dkr||j |<|j |Std|t }|jj|d}t } td |td | |d ||\} } | dk rr?r@ TokenErrorzkAuthentication token expired or invalid, please try to reauthenticate or check the scope of the credential.rArrBrErFrG)r1rHrIrJrZapredictrrKrLrrMrNrrZarunrPrQr_arunrrSr rTr$r$r%r[ysV          zQueryPowerBITool._arun)rXr'cCsd|krt|ddddd}t|dkr:tddSt|}||\}}|rld|d|jd d fS|d fSd |krd |d krd |d d krd |d d d ddfSd |d fSd |fS)z2Parse the output of the query to a markdown table.resultsrr)rowsz%0 records in result, query was valid.)Nz^0 rows returned, this might be correct, but please validate if all filter values were correct?z[Result too large, please try to be more specific or use the `TOPN` function. The result is z tokens long, the limit is z tokens.NrDz pbi.errordetailsZdetail)lenrHrJr_result_too_larger)r0rXr]rYZtoo_longlengthr$r$r%rPs(    zQueryPowerBITool._parse_output)rYr'cCsD|jr@t}||j}t||}td|||jk|fSdS)z!Tokenize the output of the query.zResult length: %s)Fr)rr Zencoding_for_modelr_encoderHrJr)r0rYZ tiktoken_encodingrar$r$r%r`s  z"QueryPowerBITool._result_too_large)N)N)"r!r"r#__doc__rstr__annotations__rrr rrrrrdictrrrintrrr&r r/r1rrRrr[rrPboolr`r$r$r$r%rsD        9 7  rc@szeZdZUdZdZeed<dZeed<eddZ e ed<Gd d d Z dee e ed d dZdee eed ddZd S)InfoPowerBIToolz2Tool for getting metadata about a PowerBI Dataset.Zschema_powerbirz Input to this tool is a comma-separated list of tables, output is the schema and sample rows for those tables. Be sure that the tables actually exist by calling list_tables_powerbi first! Example Input: "table1, table2, table3" rTrrc@seZdZdZdS)zInfoPowerBITool.ConfigTNr r$r$r$r%r&sr&Nr(r2r'cCs|j|dS)z4Get the schema for tables in a comma-separated list., )rZget_table_infosplitr0r(r2r$r$r%rRszInfoPowerBITool._runcs|j|dIdHS)Nrl)rZaget_table_informrnr$r$r%r[szInfoPowerBITool._arun)N)Nr!r"r#rdrrerfrr rrr&rrrRrr[r$r$r$r%rjs"    rjc@seZdZUdZdZeed<dZeed<eddZ e ed<Gd d d Z de ee e ed d dZde ee eed ddZd S)ListPowerBIToolzTool for getting tables names.Zlist_tables_powerbirzUInput is an empty string, output is a comma separated list of tables in the database.rTrrc@seZdZdZdS)zListPowerBITool.ConfigTNr r$r$r$r%r&sr&NrkcCsd|jSzGet the names of the tables.rljoinrrKrnr$r$r%rRszListPowerBITool._runcsd|jSrqrrrnr$r$r%r[ szListPowerBITool._arun)NN)NNror$r$r$r%rps&    rp) rdloggingtimertypingrrrrZlangchain_core.callbacksrrZlangchain_core.pydantic_v1r r Zlangchain_core.toolsr Z&langchain_community.chat_models.openair Z(langchain_community.tools.powerbi.promptr rrZ%langchain_community.utilities.powerbirr getLoggerr!rHrrjrpr$r$r$r%s    @