dh;lSSKJr SSKrSSKrSSKrSSKJrJrJrJ r J r J r J r J r JrJrJrJr SSKJrJr SSKJr SSKJrJrJr SSKJrJr SSKJr SS K J!r! SS K"J#r#J$r$J%r%J&r&J'r' \RP"\)5r*\"S 5r+SS jr,SSjr-SSjr.SSjr/SSjr0SSjr1SSjr2"SS \5r3g)) annotationsN) Any AsyncIterable AsyncIteratorCallableDictIterableIteratorListMappingOptionalTupleTypeVar)AsyncCallbackManagerForLLMRunCallbackManagerForLLMRun)BaseLLM) GenerationGenerationChunk LLMResult)get_from_dict_or_envpre_init)Field) HTTPError)before_sleep_logretryretry_if_exception_typestop_after_attemptwait_exponentialTTongyic SnSn[S[UR5[SXS9[ [ 5[ [[R5S9$)NT) multiplierminmax)reraisestopwaitr before_sleep) rr max_retriesrrrrloggerloggingWARNING)llm min_seconds max_secondss W/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/llms/tongyi.py_create_retry_decoratorr3*sJKK   0  M&y1%fgoo>  c USS:XaU$USS;a#[SUSSUSSUSS US 35e[S USSUSS US 3US 9e) z,Check the response from the completion call. status_code)iiz request_id: request_idz status_code: z code: codez message: messagez"HTTP error occurred: status_code: )response) ValueErrorr)resps r2check_responser>8s Mc! m  *4 -./ /01&\N-Y/@ B  0m1D0EF&\N-Y/@ B  r4c D^[T5nUSU4Sjj5nU"S0UD6$)*Use tenacity to retry the completion call.cR>TRR"S0UD6n[U5$Nclientcallr>)_kwargsr=r/s r2_generate_with_retry1generate_with_retry.._generate_with_retryNs#zz))d##r4rGrreturnrrCr3)r/kwargsretry_decoratorrHs` r2generate_with_retryrOJs/-c2O$$ )& ))r4c D^[T5nUSU4Sjj5nU"S0UD6$)r@c;r># TRR"S0UD6nUHn[U5v M g7frBrD)rG responsesr=r/s r2_stream_generate_with_retry?stream_generate_with_retry.._stream_generate_with_retryZs0JJOO.g. D & &s47rJrCrL)r/rMrNrSs` r2stream_generate_with_retryrUVs/-c2O'' ' 0 00r4c X# "SS5nU"U40UD6ShvN nU7v MN g7f)zAsync version of `stream_generate_with_retry`. Because the dashscope SDK doesn't provide an async API, we wrap `stream_generate_with_retry` with an async generator.c<\rSrSrSSjrS SjrS SjrS SjrSrg) 8astream_generate_with_retry.._AioTongyiGeneratoric&[U40UD6UlgN)rU generator)self_llmrGs r2__init__Aastream_generate_with_retry.._AioTongyiGenerator.__init__js7HHDNr4cU$r[rCr]s r2 __aiter__Bastream_generate_with_retry.._AioTongyiGenerator.__aiter__msKr4c# [R"5RSUR5IShvN nUbU$[eN7fr[)asyncioget_running_looprun_in_executor _safe_nextStopAsyncIteration)r]values r2 __anext__Bastream_generate_with_retry.._AioTongyiGenerator.__anext__psD!224DDdooE  (( s3AAAcN[UR5$![a gf=fr[)nextr\ StopIterationrbs r2riCastream_generate_with_retry.._AioTongyiGenerator._safe_nextys( DNN++   s  $$)r\N)r^r rGr)rKzAsyncIterator[Any])rKr) __name__ __module__ __qualname____firstlineno__r_rcrlri__static_attributes__rCr4r2_AioTongyiGeneratorrXis I  ) r4rwNrC)r/rMrwchunks r2astream_generate_with_retryrycs2 ,+39&9e 9s*(&(*(*c## [U5n[U5nUH nUS4v UnM US4v g![a gf=f7f)zWGenerate elements from an iterable, and a boolean indicating if it is the last element.NFT)iterrorpiterableiteratoritem next_items r2generate_with_last_element_markrsXH~HH~ Ek * s A 2A ?A?Ac# UR5nUR5IShvN nUShvN nUS47v UnMN![a gf=fN! US47v g7f)z]Generate elements from an async iterable, and a boolean indicating if it is the last element.NFT)rcrlrjr|s r2 agenerate_with_last_element_markrsp !!#H''))$iEk * 8 *sWAAAAAAAA AA AAAAA Ac^\rSrSr%Sr\S'Sj5rSrS\S'\ "SSS 9r S \S '\ "\ S 9r S \S'Sr S\S'\ "SSS 9rS\S'SrS\S'SrS\S'\S(Sj5r\S)Sj5r\S*Sj5r\S+U4Sjj5rS,S-SjjrS,S.S jjrS,S/S!jjrS,S0S"jjrS1S#jr\S2S3S$jj5r\S4S%j5rS&rU=r$)5r uTongyi completion model integration. Setup: Install ``dashscope`` and set environment variables ``DASHSCOPE_API_KEY``. .. code-block:: bash pip install dashscope export DASHSCOPE_API_KEY="your-api-key" Key init args — completion params: model: str Name of Tongyi model to use. top_p: float Total probability mass of tokens to consider at each step. streaming: bool Whether to stream the results or not. Key init args — client params: api_key: Optional[str] Dashscope API KEY. If not passed in will be read from env var DASHSCOPE_API_KEY. max_retries: int Maximum number of retries to make when generating. See full list of supported init args and their descriptions in the params section. Instantiate: .. code-block:: python from langchain_community.llms import Tongyi llm = Tongyi( model="qwen-max", # top_p="...", # api_key="...", # other params... ) Invoke: .. code-block:: python input_text = "用50个字左右阐述，生命的意义在于" llm.invoke(input_text) .. code-block:: python '探索、成长、连接与爱——在有限的时间里，不断学习、体验、贡献并寻找与世界和谐共存之道，让每一刻充满价值与意义。' Stream: .. code-block:: python for chunk in llm.stream(input_text): print(chunk) .. code-block:: python 探索 | 、 | 成长 | 、连接与爱。 | 在有限的时间里，寻找个人价值， | 贡献于他人，共同体验世界的美好 | ，让世界因自己的存在而更 | 温暖。 Async: .. code-block:: python await llm.ainvoke(input_text) # stream: # async for chunk in llm.astream(input_text): # print(chunk) # batch: # await llm.abatch([input_text]) .. code-block:: python '探索、成长、连接与爱。在有限的时间里，寻找个人价值，贡献于他人和社会，体验丰富多彩的情感与经历，不断学习进步，让世界因自己的存在而更美好。' c SS0$)Ndashscope_api_keyDASHSCOPE_API_KEYrCrbs r2 lc_secretsTongyi.lc_secretss#%899r4NrrEz qwen-plusmodel)defaultaliasstr model_name)default_factoryDict[str, Any] model_kwargsg?floattop_papi_keyz Optional[str]rFbool streaming intr+cg)zReturn type of llm.tongyirCrbs r2 _llm_typeTongyi._llm_typesr4c[USS/S5US'SSKnURUS'U$![a [S5ef=f![a [ S5ef=f) z?Validate that api key and python package exists in environment.rrrrNzZCould not import dashscope python package. Please install it with `pip install dashscope`.rEz`dashscope` has no `Generation` attribute, this is likely due to an old version of the dashscope package. Try upgrading it with `pip install --upgrade dashscope`.)r dashscope ImportErrorrAttributeErrorr<)clsvaluesrs r2validate_environmentTongyi.validate_environment s'; ()46I' "#    (33F8   B   :  s*AAAcjURURURS.n0UEURE$)z7Get the default parameters for calling Tongyi Qwen API.)rrr)rrrr)r] normal_paramss r2_default_paramsTongyi._default_params!s:__ZZ-- 6-54#4#455r4c4>SUR0[TU]E$)Nr)rsuper_identifying_params)r] __class__s r2rTongyi._identifying_params,sdooM1LMMr4c /nUR(al[U5S:a [S5eSnUR"USX#40UD6HnUcUnM Xg- nM UceUR UR U5/5 OUUR "SSU0UD6nUH;n [U4SU 0UD6n UR [S0URU 5D6/5 M= [USUR0S9$) Nr",Cannot stream results with multiple prompts.rr(promptr generations llm_outputrC) rlenr<_streamappend_chunk_to_generation_invocation_paramsrOr_generation_from_qwen_resprr r]promptsr( run_managerrMr generationrxparamsr completions r2 _generateTongyi._generate0s >>7|a !OPP48Jgaj$NvN%!&J'J O ) ))    9 9* EF G%)%<%<%Q$%Q&%QF!0OfOO ""N$"A"A*"MNO" #doo  r4c h# /nUR(aI[U5S:a [S5eSnUR"USX#40UD6ShvN nUcUnMXg- nMUR "SSU0UD6nUHwn [R"5RS[R"[40X S.UED65IShvN n UR [S0URU 5D6/5 My [USUR 0S9$N UceUR UR U5/5 N@Nr7f) Nr"rrr()r/rrrrC)rrr<_astreamrrrrfrgrh functoolspartialrOrrrrrs r2 _agenerateTongyi._agenerateQsH >>7|a !OPP48J#}}WQZUfU (e%!&J'J&*%<%<%Q$%Q&%QF!#*#;#;#=#M#M%%+7;/XQW/X$ ""N$"A"A*"MNO"#doo  ' (U ) ))    9 9* EF Gs8AD2 D DDA,D2=D0>AD2D)D2c + # UR"SUSS.UD6n[[U4SU0UD65HOupg[S0UR Xg5D6nU(a%UR UR UURS9 Uv MQ g7fNT)r(streamr)rxverboserC)rrrUrron_llm_new_tokentextr r]rr(rrMr stream_resp is_last_chunkrxs r2rTongyi._streamws"&!8!8" d" &," +J &t EF Ef E+ &K$11+ME,,JJ LL- K+ sBBc .# UR"SUSS.UD6n[[U4SU0UD65ShvN upg[S0UR Xg5D6nU(a-UR UR UURS9IShvN U7v M`N[N g7fr)rrryrrrrrrs r2rTongyi._astreams"&!8!8" d" &," 1Q ' FV Fv F1 ,+$11+ME!22JJ LL3 K 1 s8-BBBBA BB BBBBc j0UREUEnUbXS'URS5(aSUS'U$)Nr(rTincremental_output)rget)r]r(rMrs r2rTongyi._invocation_paramssM ""    !6N ::h  +/F' ( r4c U(a.[USS[USSUS[US5S9S9$[USSS9$) Noutputr finish_reasonr8usage)rr8 token_usagergeneration_info)r)dict)r=rs r2r!Tongyi._generation_from_qwen_resps^ (^F+ $"&x."A#L1 $T'] 3! T(^F34 4r4c>[URURS9$)Nr)rrr)rxs r2rTongyi._chunk_to_generations!11  r4rC)rKzDict[str, str])rKr)rrrKr)rKr)rKzMapping[str, Any])NN) r List[str]r(Optional[List[str]]r"Optional[CallbackManagerForLLMRun]rMrrKr) rrr(rr'Optional[AsyncCallbackManagerForLLMRun]rMrrKr) rrr(rrrrMrrKzIterator[GenerationChunk]) rrr(rrrrMrrKzAsyncIterator[GenerationChunk])r(rrMrrKr)T)r=rrrrKr)rxrrKr) rrrsrtru__doc__propertyrrE__annotations__rrrrrrrr+rrrrrrrrrr staticmethodrrrv __classcell__)rs@r2r r sJX::FCKw?J?#(#>L.>E5D',T'K}K5It/K< .66NN %):>   " 8      H%)?C $ $ "$ = $  $  $ R%):> "8    # 6%)?C "=    ( 0 )-55"&5 55,  r4)r/r rKzCallable[[Any], Any])r=rrKr)r/r rMrrKr)r}z Iterable[T]rKzIterator[Tuple[T, bool]])r}zAsyncIterable[T]rKzAsyncIterator[Tuple[T, bool]])4 __future__rrfrr-typingrrrrrr r r r r rrlangchain_core.callbacksrr#langchain_core.language_models.llmsrlangchain_core.outputsrrrlangchain_core.utilsrrpydanticrrequests.exceptionsrtenacityrrrrr getLoggerrrr,rr3r>rOrUryrrr rCr4r2rs"    8II?)   8 $ CL  $ * 1@   "  m Wm r4