|
|
# **基本信息**
|
|
|
|
|
|
## 数据名称(中文)
|
|
|
<!-- 该项数据的中文标准名称,后续沟通交流使用的规范名称,如:工商公示股东信息、失信被执行人、一般纳税人等-->
|
|
|
```buildoutcfg
|
|
|
北京欠税公告
|
|
|
```
|
|
|
|
|
|
## 数据英文名称
|
|
|
<!--英文名称,后续流程中所有涉及到英文名称均以此为准,如:partner、shixin、general_taxpayer等-->
|
|
|
```buildoutcfg
|
|
|
tax_arrears_announcement
|
|
|
```
|
|
|
|
|
|
## 采集网站(采集入口)
|
|
|
<!--采集的入口地址,不能只是一个网站域名,具体到该网站的数据入口-->
|
|
|
```buildoutcfg
|
|
|
网站:http://beijing.chinatax.gov.cn/bjsat/office/jsp/qsgg/query.jsp
|
|
|
列表页:http://beijing.chinatax.gov.cn/bjsat/office/jsp/qsgg/query.jsp
|
|
|
详情页:http://beijing.chinatax.gov.cn/bjsat/office/jsp/qsgg/QsggMx.jsp?qsggid=00000000000000821306
|
|
|
```
|
|
|
|
|
|
## 采集频率及采集策略
|
|
|
<!--说明该项数据更新频率,存量数据的更新频率及策略、新增数据的采集频率及策略-->
|
|
|
|
|
|
|
|
|
### 存量更新策略
|
|
|
<!--无需更新?每天全量更新?逐条轮询更新?多久更新完一轮?或其他-->
|
|
|
```buildoutcfg
|
|
|
每周更新一次
|
|
|
```
|
|
|
|
|
|
### 增量采集策略
|
|
|
<!--新增数据怎么来?无需单独采集新增数据?-->
|
|
|
```buildoutcfg
|
|
|
每次从头到尾运行一遍,去重得到增量数据
|
|
|
```
|
|
|
---
|
|
|
|
|
|
# **爬虫**
|
|
|
|
|
|
## 责任人
|
|
|
```buildoutcfg
|
|
|
章一锋
|
|
|
```
|
|
|
## 爬虫名称
|
|
|
<!--spider_name-->
|
|
|
```buildoutcfg
|
|
|
tax_arrears_announcement
|
|
|
```
|
|
|
## 代码地址
|
|
|
<!--爬虫的具体代码地址,不是代码所在的项目,要具体到模块或脚本文件-->
|
|
|
```buildoutcfg
|
|
|
http://tech.pingansec.com/granite/project-gravel/-/tree/develop_tax_arrears_announcement/scrapy_spiders/gravel_spiders/spiders/tax_arrears_announcement/beijing
|
|
|
```
|
|
|
## 队列名称及队列地址
|
|
|
<!--redis host port db key 优先级说明-->
|
|
|
```buildoutcfg
|
|
|
* redis host: redis://:utn@0818@bdp-mq-001.redis.rds.aliyuncs.com:6379/7
|
|
|
* redis port: 6379
|
|
|
* redis db: 7
|
|
|
* redis key: tax_arrears_announcement
|
|
|
```
|
|
|
### 优先级队列说明
|
|
|
|
|
|
|
|
|
## 任务来源
|
|
|
<!--说明爬虫任务的输入。如:来自某个数据库表等。如果来自某个数据库表则应该简要说明该表内的数据是如何维护的。-->
|
|
|
|
|
|
```buildoutcfg
|
|
|
任务数据:http://tech.pingansec.com/granite/project-gravel/-/blob/develop_tax_arrears_announcement/app_tax_arrears_announcement/data_dump/task.txt
|
|
|
导入任务配置文件路径:http://tech.pingansec.com/granite/project-gravel/-/blob/develop_tax_arrears_announcement/app_tax_arrears_announcement/data_dump/tax_arrears_announcement.yml
|
|
|
```
|
|
|
|
|
|
## 任务输入参数(样例)
|
|
|
|
|
|
### 任务样例
|
|
|
<!--注意是爬虫拿到的完整任务,而不仅仅是task_params-->
|
|
|
```json
|
|
|
{
|
|
|
"city": "beijing", # 城市
|
|
|
"task_type": "task", # 任务类型
|
|
|
"operate": 1 # 1表示企业或单位 2表示个体工商户
|
|
|
}
|
|
|
```
|
|
|
### 任务参数说明
|
|
|
<!--特有参数说明,通用参数比如spider_name,task_params,task_src,task_result等不需说明-->
|
|
|
|
|
|
|
|
|
## data_type说明
|
|
|
<!--可能产生的data_type说明-->
|
|
|
```buildoutcfg
|
|
|
list: 用于生成列表任务
|
|
|
list-item: 表示列表页中每一项数据,用于生成详情页任务
|
|
|
detail: 表示详情数据
|
|
|
```
|
|
|
|
|
|
## 爬虫结果的超级数据
|
|
|
<!--包含所有字段的json数据,每个value都要有样例值-->
|
|
|
|
|
|
```json
|
|
|
{
|
|
|
"data_type": "detail",
|
|
|
"task_params": {
|
|
|
"publish_date": "2013-09-03",
|
|
|
"rt": false,
|
|
|
"outbound": "beijing_detail",
|
|
|
"group_retry_times": 0,
|
|
|
"priority": null,
|
|
|
"task_uuid": "78480215-a35c-40ec-b4fe-ef0c5f05b906",
|
|
|
"token_scope": "beijing_detail",
|
|
|
"submit_time": "2021-11-01 16:15:02",
|
|
|
"retry_limits": 5,
|
|
|
"submitter": "taskhub",
|
|
|
"department": "国家税务总局北京市税务局",
|
|
|
"detail_url": "QsggMx.jsp?qsggid=00000000000000557314",
|
|
|
"city": "beijing",
|
|
|
"routed_count": 2,
|
|
|
"retry_times": 0,
|
|
|
"task_type": "list-item"
|
|
|
},
|
|
|
"@timestamp": "2021-11-01T08:26:10.628Z",
|
|
|
"spider_end_time": "2021-11-01 16:25:23",
|
|
|
"error_msg": "",
|
|
|
"spider_name": "tax_arrears_announcement",
|
|
|
"spider_ip": "10.8.6.51",
|
|
|
"http_code": 200,
|
|
|
"host": "bdp-ls-002",
|
|
|
"path": "/data/gravel_spiders/tax_arrears_announcement/BDP-C-1001_10.8.6.51/21262.json",
|
|
|
"type": "tax_arrears_announcement",
|
|
|
"spider_start_time": "2021-11-01 16:25:22.564",
|
|
|
"data": {
|
|
|
"publish_date": "2013-09-03",
|
|
|
"taxpayer_type": "个体工商户",
|
|
|
"new_own_tax_balance": "0.00",
|
|
|
"tax_id_number": "110***********1443",
|
|
|
"legalperson_name": "陈露",
|
|
|
"person_id_number": "110***********1443",
|
|
|
"name": "北京彩禾坊商贸中心",
|
|
|
"department": "国家税务总局北京市税务局",
|
|
|
"tax_category": "增值税",
|
|
|
"own_tax_amount": "150.90",
|
|
|
"location": "北京市顺义区博联天地小商品批发市场内"
|
|
|
},
|
|
|
"@version": "1",
|
|
|
"metadata": {},
|
|
|
"task_result": 1000
|
|
|
}
|
|
|
```
|
|
|
|
|
|
## 实际爬虫结果的数据结构
|
|
|
<!--可能与超级数据一致,可能不同的data_type的爬虫结果结构不同,超级数据是把所有data_type的结果组合在一起-->
|
|
|
|
|
|
|
|
|
## 爬虫运行环境
|
|
|
<!--udm模块?scrapy?或其他-->
|
|
|
```buildoutcfg
|
|
|
scrapy
|
|
|
```
|
|
|
|
|
|
## 爬虫部署信息
|
|
|
<!--部署在哪些机器?每个机器多少进程?项目名称是什么?-->
|
|
|
```buildoutcfg
|
|
|
爬虫运行机器:10.8.6.51
|
|
|
进程数:30
|
|
|
项目名称:tax_arrears_announcement
|
|
|
任务提交机器:10.8.6.63
|
|
|
任务提交方式:crontab
|
|
|
```
|
|
|
|
|
|
## Taskhub地址
|
|
|
```buildoutcfg
|
|
|
http://tech.pingansec.com/granite/project-taskhub/-/blob/master/taskhub/config/gravel/config.d/tax_arrears_announcement.yml
|
|
|
```
|
|
|
|
|
|
## Taskhub调度规则说明
|
|
|
```buildoutcfg
|
|
|
task_result为以下值时被过滤:
|
|
|
- 1000
|
|
|
- 1101
|
|
|
- 1102
|
|
|
- 2001
|
|
|
- 7000
|
|
|
- 9300
|
|
|
其他值的任务都会被放入队列
|
|
|
```
|
|
|
|
|
|
## 爬虫监控指标设计
|
|
|
<!--监控爬虫正常运行的指标是什么?报警规则是什么?-->
|
|
|
|
|
|
## 爬虫待采集结果目录
|
|
|
|
|
|
---
|
|
|
```buildoutcfg
|
|
|
/data/gravel_spiders/tax_arrears_announcement
|
|
|
```
|
|
|
# **数据归集**
|
|
|
## 责任人
|
|
|
|
|
|
## 数据归集方式
|
|
|
|
|
|
- [ ] 爬虫直接写kafka
|
|
|
|
|
|
- [ x ] 爬虫写文件logstash采集
|
|
|
|
|
|
|
|
|
## 归集后存放目录
|
|
|
|
|
|
|
|
|
## logstash配置文件名称
|
|
|
|
|
|
|
|
|
## logstash文件采集type
|
|
|
|
|
|
|
|
|
## 数据归集的topic
|
|
|
```buildoutcfg
|
|
|
general-taxpayer
|
|
|
```
|
|
|
|
|
|
## ES日志索引及筛选条件
|
|
|
```buildoutcfg
|
|
|
gravel-spider-data* spider_name is tax_arrears_announment city is beijing
|
|
|
```
|
|
|
|
|
|
|
|
|
## 监控指标看板
|
|
|
|
|
|
|
|
|
## 数据保留策略
|
|
|
|
|
|
|
|
|
---
|
|
|
|
|
|
# **数据清洗**
|
|
|
|
|
|
## 责任人
|
|
|
|
|
|
|
|
|
## 代码地址
|
|
|
|
|
|
|
|
|
## 部署地址
|
|
|
<!--机器及线上代码地址-->
|
|
|
|
|
|
|
|
|
## 部署方法及说明
|
|
|
<!--运行方法及运行命令、supervisor配置、supervisor的program等-->
|
|
|
- [ ] crontab + data_pump
|
|
|
- [ ] supervisor + data_pump
|
|
|
- [ ] supervisor + consumer
|
|
|
|
|
|
## 数据接收来源
|
|
|
<!--来源于kafka还是归集的文件、topic的group?-->
|
|
|
|
|
|
|
|
|
## 数据存储表地址
|
|
|
|
|
|
* 数据库地址:
|
|
|
* 表名: |
|
|
\ No newline at end of file |