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

add workflow 市场News-Agents调度,dev

This commit is contained in:
root 2025-12-26 11:12:14 +08:00
parent 32aaab10b1
commit a59c620930
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dev/workflow/TK_Cust/agents_market_newsletter/市场信息汇总/agents_market_summar.py
View File

@ -189,8 +189,8 @@ def main():
SELECT distinct SELECT distinct
web_url, web_url,
(ROW_NUMBER() OVER (ORDER BY web_url) - 1) / 5 as batch_num (ROW_NUMBER() OVER (ORDER BY web_url) - 1) / 5 as batch_num
FROM p70_ai_intelligence.t_channel FROM p70_ai_intelligence.t_channel_news
WHERE type = 'News'
) )
SELECT SELECT
STRING_AGG(web_url, E'\n') as batched_urls STRING_AGG(web_url, E'\n') as batched_urls

2
dev/workflow/TK_Cust/agents_market_newsletter/招聘信息调用/agents_recuriments.py
View File

@ -185,7 +185,7 @@ def main():
if flag: if flag:
# 初始化 # 初始化
db_manager = DatabaseManager(db_config) db_manager = DatabaseManager(db_config)
custom_query = """ select concat('|',web_url,'|',industry,'|') from p70_ai_intelligence.t_channel where type='招聘' """ custom_query = """ select concat('|',web_url,'|',industry,'|') from p70_ai_intelligence.t_channel_recruitment """
try: try:
# 从数据库获取URL列表 # 从数据库获取URL列表