Skip to content

M
meta_base_code
Commit d923e47a authored by litaolemo's avatar litaolemo
Browse files
Options

update

parent 0ad276bb
Hide whitespace changes
Inline Side-by-side
Showing with 39 additions and 19 deletions
README.md
View file @ d923e47a
......@@ -10,4 +10,8 @@ metabase 数据开发相关代码
/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
/opt/spark/bin/spark-submit --master yarn --deploy-mode client --queue root.strategy --driver-memory 16g --executor-memory 1g --executor-cores 2 --num-executors 100 --conf spark.default.parallelism=100 --conf spark.storage.memoryFraction=0.5 --conf spark.shuffle.memoryFraction=0.3 --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/search_strategy_d.py
/opt/spark/bin/spark-submit --master yarn --deploy-mode client --queue root.strategy --driver-memory 16g --executor-memory 2g --executor-cores 4 --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/core_indicators_monitoring.py
/opt/spark/bin/spark-submit --master yarn --deploy-mode client --queue root.strategy --driver-memory 16g --executor-memory 2g --executor-cores 4 --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/advertisement_strategy_d.py
/opt/spark/bin/spark-submit --master yarn --deploy-mode client --queue root.strategy --driver-memory 16g --executor-memory 1g --executor-cores 4 --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/advertisement_strategy_d.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/search_meigou_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/search_diary_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/search_tractate_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/search_answer_ctr.py
task.sh
View file @ d923e47a
......@@ -2,5 +2,6 @@ source /srv/envs/esmm/bin/activate
/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
/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/search_strategy_d.py
/opt/spark/bin/spark-submit --master yarn --deploy-mode client --queue root.strategy --driver-memory 16g --executor-memory 2g --executor-cores 4 --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/core_indicators_monitoring.py
/opt/spark/bin/spark-submit --master yarn --deploy-mode client --queue root.strategy --driver-memory 16g --executor-memory 1g --executor-cores 4 --num-executors 120 --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/core_indicators_monitoring.py
/opt/spark/bin/spark-submit --master yarn --deploy-mode client --queue root.strategy --driver-memory 16g --executor-memory 1g --executor-cores 4 --num-executors 120 --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/search_meigou_ctr.py
task/search_answer_ctr.py
View file @ d923e47a
......@@ -204,11 +204,15 @@ and (dev.device_id is null or dev.device_id='')
print(res)
if res.ACTIVE_TYPE:
if res.ACTIVE_TYPE in ('1', '2'):
res_dict["新增"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
res_dict["新增"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
if res.CLICK_NUM:
res_dict["新增"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
if res.EXPOSURE:
res_dict["新增"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
else:
res_dict["老活"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
res_dict["老活"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
if res.CLICK_NUM:
res_dict["老活"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
if res.EXPOSURE:
res_dict["老活"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
for active_type in res_dict:
for device_os_type in res_dict[active_type]:
......
task/search_diary_ctr.py
View file @ d923e47a
......@@ -204,11 +204,15 @@ and (dev.device_id is null or dev.device_id='')
print(res)
if res.ACTIVE_TYPE:
if res.ACTIVE_TYPE in ('1', '2'):
res_dict["新增"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
res_dict["新增"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
if res.CLICK_NUM:
res_dict["新增"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
if res.EXPOSURE:
res_dict["新增"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
else:
res_dict["老活"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
res_dict["老活"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
if res.CLICK_NUM:
res_dict["老活"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
if res.EXPOSURE:
res_dict["老活"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
for active_type in res_dict:
for device_os_type in res_dict[active_type]:
......
task/search_meigou_ctr.py
View file @ d923e47a
......@@ -205,11 +205,15 @@ and (dev.device_id is null or dev.device_id='')
print(res)
if res.ACTIVE_TYPE:
if res.ACTIVE_TYPE in ('1', '2'):
res_dict["新增"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
res_dict["新增"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
if res.CLICK_NUM:
res_dict["新增"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
if res.EXPOSURE:
res_dict["新增"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
else:
res_dict["老活"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
res_dict["老活"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
if res.CLICK_NUM:
res_dict["老活"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
if res.EXPOSURE:
res_dict["老活"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
for active_type in res_dict:
for device_os_type in res_dict[active_type]:
......
task/search_tractate_ctr.py
View file @ d923e47a
......@@ -204,12 +204,15 @@ and (dev.device_id is null or dev.device_id='')
print(res)
if res.ACTIVE_TYPE:
if res.ACTIVE_TYPE in ('1', '2'):
res_dict["新增"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
res_dict["新增"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
if res.CLICK_NUM:
res_dict["新增"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
if res.EXPOSURE:
res_dict["新增"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
else:
res_dict["老活"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
res_dict["老活"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
if res.CLICK_NUM:
res_dict["老活"][res.DEVICE_OS_TYPE]["click_num"] += res.CLICK_NUM
if res.EXPOSURE:
res_dict["老活"][res.DEVICE_OS_TYPE]["exposure"] += res.EXPOSURE
for active_type in res_dict:
for device_os_type in res_dict[active_type]:
partition_date = yesterday_str
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment