dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow 市场-Agents调度,dev

This commit is contained in:
root 2025-11-20 11:43:55 +08:00
parent c4d42a6aab
commit b3af3b1f97
1 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
dev/workflow/TK_Cust/agents_market_newsletter/泰克产品相关性分析/tk_product_prefer.py
View File

@ -72,8 +72,9 @@ class APIClient:
Returns: Returns:
API响应数据 API响应数据
""" """
inputs_data = {}
payload = { payload = {
"inputs": {}, "inputs": inputs_data,
"response_mode": "blocking", "response_mode": "blocking",
"user": "admin" "user": "admin"
} }
@ -108,7 +109,7 @@ class APIClient:
} }
def call_api_with_query(self, query: str = None) -> Dict[str, Any]: def call_api_with_query(self, inputs: Dict[str, Any] = None, query: str = None) -> Dict[str, Any]:
"""直接调用带inputs参数的API """直接调用带inputs参数的API
Args: Args:
@ -118,11 +119,10 @@ class APIClient:
API响应数据 API响应数据
""" """
payload = json.dumps({ payload = json.dumps({
"inputs": None, "inputs": inputs,
"query": query, "query": query,
"response_mode": "streaming", "response_mode": "streaming",
"user": "admin", "user": "admin"
"conversation_id":""
}) })
try: try:
@ -307,9 +307,10 @@ def main():
else: else:
#agent #agent
inputs_data = {}
query = text query = text
logger.info(f"call_api_with_query") logger.info(f"call_api_with_query")
result = api_client.call_api_with_query(query) result = api_client.call_api_with_query(inputs_data, query)
if result['success']: if result['success']:
logger.info(f"URL {text} 处理成功") logger.info(f"URL {text} 处理成功")
@ -329,6 +330,9 @@ def main():
else: else:
logger.info("调用不带inputs参数的API示例") logger.info("调用不带inputs参数的API示例")
if type == 'workflow': if type == 'workflow':
inputs_data = {}
result2 = api_client.call_api_without_inputs() result2 = api_client.call_api_without_inputs()
if result2['success']: if result2['success']:
@ -338,6 +342,8 @@ def main():
else: else:
#agent #agent
inputs_data = {}
result2 = api_client.call_api_without_query() result2 = api_client.call_api_without_query()
if result2['success']: if result2['success']: