data_integration_celery

通过celery定期执行更相关任务，将万得wind，同花顺ifind，东方财富choice等数据终端的数据进行整合，清洗，一致化，供其他系统数据分析使用

为了满足不同环境需要，也支持不使用celery，直接运行

下载页面	windows安装版地址
RabbitMQ：下载地址；	rabbitmq-server-3.7.14.exe
RabbitMQ 运行依赖于 Erlang：下载地址；	OTP 21.3 Windows 64-bit Binary File (92618042)

-P 命令只要是为了在win10 下可以正常运行详见 issue，其他环境下可以去除
-P, --pool Pool implementation: prefork (default), eventlet, gevent or solo.
-c 命令后面的数字表示平行运行的 worker 数量，建议不要超过CPU核数
-l, --loglevel Logging level, choose between DEBUG, INFO, WARNING, ERROR, CRITICAL, or FATAL.

2. 启动 beat

celery beat -A tasks

CeleryConfig 中的定时任务将通过 beat 自动启动

3. Schedules Configuration

推荐配置

from celery.schedules import crontab


class CeleryConfig:
    # Celery settings
    broker_url = 'amqp://mg:***@localhost:5672/celery_tasks',
    result_backend = 'amqp://mg:***@localhost:5672/backend'
    accept_content = ['json']  # , 'pickle'
    timezone = 'Asia/Shanghai'
    imports = ('tasks',)
    beat_schedule = {
        'daily_task': {
            'task': 'tasks.grouped_task_daily',
            'schedule': crontab(hour='16', minute='03', day_of_week='1-5'),
        },
        'weekly_task': {
            'task': 'tasks.grouped_task_weekly',
            'schedule': crontab(hour='10', day_of_week='6'),
        },
    }
    broker_heartbeat = 0

具体命令及执行时间可根据需要进行配置

六、MySQL 配置方法

MySQL 5.7 下载地址
Ubuntu 系统可直接 apt 方式安装

Ubuntu 18.04 环境下安装 MySQL，5.7
```
sudo apt install mysql-server
```

默认情况下，没有输入用户名密码的地方，因此，安装完后需要手动重置Root密码，方法如下：

cd /etc/mysql/debian.cnf
sudo more debian.cnf

出现类似这样的东西

# Automatically generated for Debian scripts. DO NOT TOUCH!
[client]
host     = localhost
user     = debian-sys-maint
password = j1bsABuuDRGKCV5s
socket   = /var/run/mysqld/mysqld.sock
[mysql_upgrade]
host     = localhost
user     = debian-sys-maint
password = j1bsABuuDRGKCV5s
socket   = /var/run/mysqld/mysqld.sock

以debian-sys-maint为用户名登录，密码就是debian.cnf里那个 password = 后面的东西。使用mysql -u debian-sys-maint -p 进行登录。进入mysql之后修改MySQL的密码，具体的操作如下用命令：

use mysql;

update user set authentication_string=PASSWORD("Dcba4321") where user='root';

update user set plugin="mysql_native_password"; 
 
flush privileges;

然后就可以用过root用户登陆了
```
mysql -uroot -p
```

创建用户 mg 默认密码 Abcd1234

CREATE USER 'mg'@'%' IDENTIFIED BY 'Abcd1234';

创建数据库 md_integration

CREATE DATABASE `md_integration` default charset utf8 collate utf8_general_ci;

授权

grant all privileges on md_integration.* to 'mg'@'localhost' identified by 'Abcd1234'; 

flush privileges; #刷新系统权限表

七、MySQL 参数调整

部分数据过大可能导致数据库连接、存储过程中失效或者速度缓慢，建议调整一下参数：

参数	数值	描述
max_allowed_packet	500M	配置MySQL允许的最大数据包大小，解决 Lost connection to MySQL server during query 问题
wait_timeout	172800	解决 MySQL server has gone away 的问题
interactive_timeout	172800	解决 MySQL server has gone away 的问题
innodb_buffer_pool_size	1024M	Innodb_buffer_pool_pages_data / Innodb_buffer_pool_pages_total * 100%，建议使用物理内存的75%
sort_buffer_size	4M	解决 Sort aborted: Out of sort memory, consider increasing server sort buffer size。默认只有 256K。On Linux, there are thresholds of 256KB and 2MB where larger values may significantly slow down memory allocation

参数调整方法:

修改 my.cnf 文件

执行 sql命令

set global max_allowed_packet=500*1024*1024;

快速查询数据库中各个表的数据条数命令

select a.TABLE_NAME,a.TABLE_ROWS from information_schema.`TABLES` a WHERE a.TABLE_SCHEMA='md_integration' ORDER BY a.TABLE_ROWS desc

hjhhjhhjh/data_integration_celery

data_integration_celery

目录：

一、环境依赖及安装配置

二、首次运行前环境配置

三、RabbitMQ 系统配置

1. 用户创建及权限配置

2. 启动web端

四、Window CMD 启动

五、celery 启动方法

1. 启动 worker

2. 启动 beat

3. Schedules Configuration

六、MySQL 配置方法

七、MySQL 参数调整