Browse Source

update odps config

liqian 3 years ago
parent
commit
236067d975
3 changed files with 13 additions and 6 deletions
  1. 7 0
      config.py
  2. 3 3
      rov_data_check.py
  3. 3 3
      utils.py

+ 7 - 0
config.py

@@ -22,6 +22,13 @@ class BaseConfig(object):
     # oss 目标Bucket
     BUCKET_NAME = 'ali-recommend'
 
+    # ODPS服务配置
+    ODPS_CONFIG = {
+        'ENDPOINT': 'http://service.cn.maxcompute.aliyun.com/api',
+        'ACCESSID': 'LTAIWYUujJAm7CbH',
+        'ACCESSKEY': 'RfSjdiWwED1sGFlsjXv0DlfTnZTG1P',
+    }
+
     # 训练数据截止时间距当前日期间隔天数
     TRAIN_DIFF = 7
     # 训练数据所需数据范围天数

+ 3 - 3
rov_data_check.py

@@ -33,10 +33,10 @@ def rov_train_recall_pool_update():
 
 def data_check(project, table, date):
     odps = ODPS(
-        access_id='LTAIWYUujJAm7CbH',
-        secret_access_key='RfSjdiWwED1sGFlsjXv0DlfTnZTG1P',
+        access_id=config_.ODPS_CONFIG['ACCESSID'],
+        secret_access_key=config_.ODPS_CONFIG['ACCESSKEY'],
         project=project,
-        endpoint='http://service.cn.maxcompute.aliyun.com/api',
+        endpoint=config_.ODPS_CONFIG['ENDPOINT'],
         connect_timeout=3000,
         read_timeout=500000,
         pool_maxsize=1000,

+ 3 - 3
utils.py

@@ -44,10 +44,10 @@ def get_data_from_odps(date, project, table, connect_timeout=3000, read_timeout=
     :return: records
     """
     odps = ODPS(
-        access_id='LTAI4FtW5ZzxMvdw35aNkmcp',
-        secret_access_key='0VKnydcaHK3ITjylbgUsLubX6rwiwc',
+        access_id=config_.ODPS_CONFIG['ACCESSID'],
+        secret_access_key=config_.ODPS_CONFIG['ACCESSKEY'],
         project=project,
-        endpoint='http://service.cn.maxcompute.aliyun.com/api',
+        endpoint=config_.ODPS_CONFIG['ENDPOINT'],
         connect_timeout=connect_timeout,
         read_timeout=read_timeout,
         pool_maxsize=pool_maxsize,