|
|
@@ -72,6 +72,17 @@ def get_accounts(db_client: DatabaseConnector) -> List[Dict]:
|
|
|
"account_type": line[4], # 订阅号 or 服务号
|
|
|
"account_auth": line[5]
|
|
|
"""
|
|
|
+ illegal_accounts = [
|
|
|
+ 'gh_4c058673c07e',
|
|
|
+ 'gh_de9f9ebc976b',
|
|
|
+ 'gh_7b4a5f86d68c',
|
|
|
+ 'gh_f902cea89e48',
|
|
|
+ 'gh_789a40fe7935',
|
|
|
+ 'gh_cd041ed721e6',
|
|
|
+ 'gh_62d7f423f382',
|
|
|
+ 'gh_043223059726',
|
|
|
+ 'gh_5bb79339a1f4'
|
|
|
+ ]
|
|
|
account_list_with_out_using_status = aiditApi.get_publish_account_from_aigc()
|
|
|
account_status_dict = get_account_status(db_client)
|
|
|
account_list = [
|
|
|
@@ -81,6 +92,7 @@ def get_accounts(db_client: DatabaseConnector) -> List[Dict]:
|
|
|
}
|
|
|
for item in account_list_with_out_using_status
|
|
|
]
|
|
|
+ account_list = [account for account in account_list if account['ghId'] not in illegal_accounts]
|
|
|
return account_list
|
|
|
|
|
|
|
|
|
@@ -487,7 +499,7 @@ def update_job(piaoquan_crawler_db_client, aigc_db_client):
|
|
|
try:
|
|
|
update_single_account(piaoquan_crawler_db_client, sub_item)
|
|
|
success_count += 1
|
|
|
- time.sleep(5)
|
|
|
+ # time.sleep(5)
|
|
|
except Exception as e:
|
|
|
fail_count += 1
|
|
|
log(
|
|
|
@@ -495,6 +507,11 @@ def update_job(piaoquan_crawler_db_client, aigc_db_client):
|
|
|
function="update_job",
|
|
|
message="单个账号文章更新失败, 报错信息是: {}".format(e),
|
|
|
status="fail",
|
|
|
+ data={
|
|
|
+ "account": sub_item,
|
|
|
+ "error": str(e),
|
|
|
+ "traceback": traceback.format_exc()
|
|
|
+ }
|
|
|
)
|
|
|
log(
|
|
|
task="updatePublishedMsgDaily",
|
luojunhui