gSSKJrJrJrJrJrJr SSKJr SSK J r SSK J r \ "5 SSKrSSKr0r"SS\5rSrS r\S :Xa\"5 gg) ) AckMessageChatbotMessageDingTalkStreamClient CredentialChatbotHandlerCallbackMessage) AgentClass)add_user) load_dotenvNc6^\rSrSrU4SjrS\4SjrSrU=r$)EchoTextHandler c*>[[U] 5 g)N)superr__init__)self __class__s J/Volumes/MOVESPEED/AI课程/xiaolang/DingTalk_langchain/src/DingWebHook.pyrEchoTextHandler.__init__s nd,.callbackc# [R"UR5n[U5 [UR5 URR R 5nURSn[SU5 [5RU5n[U5 URUSU5 [RS4$7f)N senderStaffIduseridoutputOK) r from_dictdataprinttextcontentstripr r run_agent reply_textr STATUS_OK)rrincoming_messager rmsgs rprocessEchoTextHandler.processs)33HMMB  hmm$$,,224/&!l$$T* c  H '78##T))sC C ) __name__ __module__ __qualname____firstlineno__rrr(__static_attributes__ __classcell__)rs@rr r s/ *o * *rr c[R"[RS[R"5[R"S5/S9 [R "S5$)zSetup logging configurationz4%(asctime)s - %(name)s - %(levelname)s - %(message)szdingtalk_connection.log)levelformathandlersDingTalk)logging basicConfigINFO StreamHandler FileHandler getLoggerr*rr setup_loggingr<sM llE  ! ! #    9 :    Z ((rcV[5nURS5 URS[R"S535 URS5 [ [R"S5[R"S55n[ U5nURS5 UR [R[55 URS5 URS5 UR5 g![anURS U3S S 9 SnAgSnAff=f) NzStarting DingTalk Stream ClientzApp ID: DINGDING_IDz(Using credentials to connect to DingTalkDINGDING_SECRETz$DingTalk client created successfullyz.Registered callback handler for ChatbotMessagezStarting DingTalk client...zError connecting to DingTalk: T)exc_info) r<infoosgetenvrrregister_callback_handlerrTOPICr start_forever Exceptionerror)logger credentialclientes rmainrM+s _F KK12 KK(299]3456 KK:< J - 8"))DU:VW %j1 :; (()=)=?PQ DE  12 J 5aS9D IJsB*D D( D##D(__main__)dingtalk_streamrrrrrr src.Agentsr src.Storager dotenvr _load_dotenvrBr6 user_storager r<rMr+r*rrrUsQww! .   *n*$ )J. zFr