| 1234567891011121314151617181920 |
- from datetime import datetime, timedelta
- async def get_titles_from_produce_plan(pool, plan_id, threshold=None):
- if not threshold:
- fifteen_days_ago = datetime.now() - timedelta(days=30)
- threshold = fifteen_days_ago.strftime("%Y%m%d") + 15 * "0"
- query = f"""
- select distinct t2.title
- from produce_plan_input_source t3
- join crawler_plan_result_rel t1 on t3.input_source_value = t1.plan_id
- join crawler_content t2 on t1.channel_source_id = t2.channel_content_id
- where t3.plan_id = %s
- and t3.input_source_value > %s;
- """
- response = await pool.async_fetch(
- query=query, db_name="aigc", params=(plan_id, threshold)
- )
- return tuple([i["title"] for i in response])
|
