辽宁省人民政府

REITs专题数据/policy-liaoning.py

-import time
+import time
@@ -16,7 +16,7 @@ policy = Policy()
 
 
 topic = 'policy'
-webname = '天津市人民政府'
+webname = '辽宁省人民政府'
 headers = {
     'User_Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/119.0.0.0 Safari/537.36 Edg/119.0.0.0'
 }
@@ -73,8 +73,8 @@ def doJob():
             'title': title,
             'publishDate': publishDate,
             'origin': '辽宁省人民政府',
-            'sourceAddress': url,
-            'writtenDate': '',
+            'sourceAddress': href,
+            'writtenDate': None,
             'organ': '',
             'topicClassification': '',
             'issuedNumber': pub_hao,
@@ -84,8 +84,8 @@ def doJob():
         }
         try:
             baseCore.sendkafka(dic_info, topic)
-            baseCore.r.sadd('REITs::' + webname, url)
-            log.info(f'采集成功--{title}--{url}')
+            baseCore.r.sadd('REITs::' + webname, href)
+            log.info(f'采集成功--{title}--{href}')
         except Exception as e:
             continue
         num += 1