§
|
<.hÈ ã óx d Z ddlZddlZddlmZmZmZmZ ddlm Z ddl
|
m Z G d d¦ « Z e ¦ « Z dS )u
|
DifyAI API客æ·ç«¯
|
é N)ÚListÚDictÚOptionalÚAny)Úlogger)Úsettingsc ó e Zd ZdZd Z d dededee dedeeee f f
|
d Z
|
dededee eee f fd
|
Z dS ) Ú
|
DifyClientu DifyAI API客æ·ç«¯c óô t j d¦ « | _ ddt j d| _ t j ¦ « | _ | j j | j ¦ « d S )Nú/zapplication/jsonzBearer )z Content-TypeÚ Authorization)
|
r Ú dify_base_urlÚrstripÚbase_urlÚ dify_api_keyÚheadersÚrequestsÚSessionÚsessionÚupdate)Úselfs ú4d:\project\python\ECloud\app\services\dify_client.pyÚ__init__zDifyClient.__init__ sl Ý Ô.×5Ò5°cÑ:Ô: à .Ø >¥xÔ'<Ð >Ð >ð
|
ð
|
õ Ô'Ñ)Ô) Ø Ô ×#Ò# D¤LÑ1Ô1Ð1Ð1Ð1ó NÚqueryÚuserÚconversation_idÚ max_retriesÚreturnc ó | t j }| j d}|d|i d}|r||d< d}||k r» t j d| d| d | ¦ « | j ||d
|
¬ ¦ « }| ¦ « | ¦ « } d | v r3d| v r/t j d | d| d¦ « ¦ « | S t j
|
d| d| ¦ « n¶# t j j $ r t j d| d | ¦ « Y nt j j $ r4}
|
t j
|
d| d | dt! |
|
¦ « ¦ « Y d}
|
~
|
nDd}
|
~
|
wt" $ r4}
|
t j
|
d| d | dt! |
|
¦ « ¦ « Y d}
|
~
|
nd}
|
~
|
ww xY w|dz }||k r>t j |z } t j d| d| d¦ « t' j | ¦ « ||k °»t j
|
d| d| ¦ « dS )u6
|
åé对è¯æ¶æ¯ï¼éæµå¼æ¨¡å¼ï¼
|
|
Args:
|
query: ç¨æ·è¾å
¥/æé®å
容
|
user: ç¨æ·æ è¯
|
conversation_id: ä¼è¯IDï¼å¯éï¼
|
max_retries: æ大éè¯æ¬¡æ°
|
|
Returns:
|
ååºæ°æ®åå
¸ï¼å¤±è´¥è¿åNone
|
Nz/chat-messagesÚblocking)r Ú response_moder Úinputsr r u åéDifyæ¶æ¯: user=z, conversation_id=z, retry=é< )ÚjsonÚtimeoutÚansweru Difyæ¶æ¯åéæå: user=u Difyååºæ ¼å¼å¼å¸¸: user=ú , response=u Dify请æ±è¶
æ¶: user=u Difyç½ç»é误: user=ú, error=u Dify请æ±å¼å¸¸: user=é u çå¾
éè¯: user=z , wait_time=Úsu8 Difyæ¶æ¯åé失败ï¼å·²è¾¾æ大éè¯æ¬¡æ°: user=z, max_retries=)r Úmax_retry_countr r Úinfor ÚpostÚraise_for_statusr% ÚgetÚerrorr Ú
|
exceptionsÚTimeoutÚwarningÚRequestExceptionÚstrÚ ExceptionÚ retry_delayÚtimeÚsleep) r r r r r ÚurlÚpayloadÚ retry_countÚresponseÚresultÚeÚ wait_times r Úsend_chat_messagez DifyClient.send_chat_message s ð& Ð Ý"Ô2Kà Ð.Ð.Ð.àØ 'ØØð
|
ð
|
ð ð 9Ø)8GÐ%Ñ &à Ø[Ò(Ñ(ð Ý Øl¨dÐlÐlÀoÐlÐlÐ_jÐlÐlñô ð ð <×,Ò,¨S°wÈÐ,ÑKÔKØ×)Ò)Ñ+Ô+Ð+à! ð vÐ%Ð%Ð*;¸vÐ*EÐ*EÝKØo¸ÐoÐoÐPV×PZÒPZÐ[lÑPmÔPmÐoÐoñô ð ð "MåLÐ!ZÀÐ!ZÐ!ZÐRXÐ!ZÐ!ZÑ[Ô[Ð[Ð[øåÔ&Ô.ð Vð Vð VÝÐ T¸Ð TÐ TÀ{Ð TÐ TÑUÔUÐUÐUÐUÝÔ&Ô7ð ð ð Ý ØY¨dÐYÐY¸KÐYÐYÕQTÐUVÑQWÔQWÐYÐYñô ð ð ð ð ð ð øøøøõ ð ð ð Ý ØY¨dÐYÐY¸KÐYÐYÕQTÐUVÑQWÔQWÐYÐYñô ð ð ð ð ð ð øøøøð øøøð
|
1Ñ KØkÒ)Ð)Ý $Ô 0°;Ñ > Ý Ð P°$Ð PÐ PÀIÐ PÐ PÐ PÑQÔQÐQÝ
|
9Ñ%Ô%Ð%ðG [Ò(Ñ(õJ Ø hÀtÐ hÐ hÐ[fÐ hÐ hñ
|
ô
|
ð
|
ð ts0 ±BC% Ã
|
C% Ã%.FÄFÄ(*EÅ FÅ$*FÆFc ód | j d}||d}t j d| d| ¦ « | j ||d¬¦ « }| ¦ « | ¦ « }d|v r t j d| ¦ « |d S t j d | d
|
| ¦ « d S # t j j
|
$ r2}t j d | d t |¦ « ¦ « Y d }~d S d }~wt $ r2}t j d| d t |¦ « ¦ « Y d }~d S d }~ww xY w)u¼
|
è·å对è¯åå²æ¶æ¯
|
|
Args:
|
conversation_id: ä¼è¯ID
|
user: ç¨æ·æ è¯
|
|
Returns:
|
æ¶æ¯å表ï¼å¤±è´¥è¿åNone
|
z /messages)r r u$ è·å对è¯åå²: conversation_id=z, user=é )Úparamsr& Údatau* æåè·å对è¯åå²: conversation_id=u6 è·å对è¯åå²ååºæ ¼å¼å¼å¸¸: conversation_id=r( Nu0 è·å对è¯åå²ç½ç»é误: conversation_id=r) u* è·å对è¯åå²å¼å¸¸: conversation_id=) r r r- r r0 r/ r% r1 r r2 r5 r6 r7 )r r r r; rE r> r? r@ s r Úget_conversation_messagesz$DifyClient.get_conversation_messagese s ð Ø]Ð-Ð-Ð-CØ)8À$ÐGÐGFå KÐ]¸Ð]Ð]ÐW[Ð]Ð]Ñ ^Ô ^Ð ^à|×'Ò'¨°FÀBÐ'ÑGÔGHØ × %Ò %Ñ 'Ô 'Ð 'à ]]__FàÐ Ð Ý Ð ZÈ Ð ZÐ ZÑ[Ô[Ð[Ø f~Ð%å ØqÈ_ÐqÐqÐioÐqÐqñô ð ð tøåÔ"Ô3ð ð ð Ý LØdÀ?ÐdÐdÕ\_Ð`aÑ\bÔ\bÐdÐdñ ô ð ð 44444øøøøÝð ð ð Ý LØ^¸_Ð^Ð^ÕVYÐZ[ÑV\ÔV\Ð^Ð^ñ ô ð ð 44444øøøøð øøøs* BB/ ÂB/ Â/D/Ã'C0Ã0 D/Ã='D*Ä*D/)NN) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r6 r Úintr r rB r rG © r r r
|
r
|
sÔ Ø Ð ð2ð 2ð 2ð *.Ø ð Kð KàðKð ðKð " # ð Kð
|
ð Kð
|
$sCx.Ô !ð Kð Kð Kð KðZ*Ø "ð*Ø*-ð*à $tC H~Ô&Ô 'ð*ð *ð *ð *ð *ð *r r
|
)rK r r9 Útypingr r r r Úlogurur Úconfigr r
|
Ú dify_clientrM r r ú<module>rR s ððð ð Ø Ø ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð ðCð Cð Cð Cð Cñ Cô Cð CðN jll r
|
