|
|
@@ -17,10 +17,10 @@ log_ = Log()
|
|
|
def execute_sql_from_odps(project, sql, connect_timeout=3000, read_timeout=500000,
|
|
|
pool_maxsize=1000, pool_connections=1000):
|
|
|
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,
|
