update

README.md

@@ -8,6 +8,9 @@ metabase 数据开发相关代码
 4. 任务执行为crontab任务 可用crontab -e 修改
 5. py程序文件名即为metabase所使用的的表名
 
+es/celery 状态监测代码
+1. /celery_stats文件夹中
+
 ```
 /opt/spark/bin/spark-submit --master yarn --deploy-mode client --queue root.strategy --driver-memory 16g --executor-memory 1g --executor-cores 1 --num-executors 70 --conf spark.default.parallelism=100 --conf spark.storage.memoryFraction=0.5 --conf spark.shuffle.memoryFraction=0.3  --conf spark.locality.wait=0 --jars /srv/apps/tispark-core-2.1-SNAPSHOT-jar-with-dependencies.jar,/srv/apps/spark-connector_2.11-1.9.0-rc2.jar,/srv/apps/mysql-connector-java-5.1.38.jar /srv/apps/meta_base_code/task/conent_detail_page_grayscale_ctr.py
 /opt/spark/bin/spark-submit --master yarn --deploy-mode client --queue root.strategy --driver-memory 16g --executor-memory 1g --executor-cores 1 --num-executors 70 --conf spark.default.parallelism=100 --conf spark.storage.memoryFraction=0.5 --conf spark.shuffle.memoryFraction=0.3  --conf spark.locality.wait=0 --jars /srv/apps/tispark-core-2.1-SNAPSHOT-jar-with-dependencies.jar,/srv/apps/spark-connector_2.11-1.9.0-rc2.jar,/srv/apps/mysql-connector-java-5.1.38.jar /srv/apps/meta_base_code/task/recommend_strategy_d.py

celery_stats/celery_stats_monitor.py

@@ -76,6 +76,7 @@ def len_list_and_send_msg(redis_clint, key_name, rules, per_sec=10):
 
 if __name__ == "__main__":
     rules = Parse_data()
+    # 队列名和队列redis地址
     redis_clicnt_dct = {
         "gaia-dbmw": redis_old_gaia,
         "tapir-gaia-service": redis_old_gaia,