1、python脚本调用odps流程如果平台python版本比较低会无法使用run_script方法目前作者没有找到解决的办法fromodpsimportODPS# 创建 ODPS 对象如果该脚本是在阿里云DataWorks上运行的下面4句可删了access_idyour-access-idaccess_keyyour-access-keyproject_nameyour-project-nameodpsODPS(access_id,access_key,project_name)# 指定脚本名称script_namemy_script# 定义参数params{param1:value1,param2:value2}# 调用 ODPS Scriptinstanceodps.run_script(script_name,paramsparams)instance.wait_for_success()# 获取查询结果withinstance.open_reader()asreader:forrecordinreader:print(record)2、python脚本调用执行sqlfromodpsimportODPS# 创建 ODPS 对象如果该脚本是在阿里云DataWorks上运行的下面4句可删了access_idyour-access-idaccess_keyyour-access-keyproject_nameyour-project-nameodpsODPS(access_id,access_key,project_name)# 定义参数param1value1param2value2# 动态构建 SQL 语句sqlfSELECT * FROM my_table WHERE column1 {param1} AND column2 {param2}# 执行 SQLinstanceodps.run_sql(sql)instance.wait_for_success()# 获取查询结果withinstance.open_reader()asreader:forrecordinreader:print(record) 阿里云 MaxCompute通过python脚本调用odps流程和执行sql
1、python脚本调用odps流程如果平台python版本比较低会无法使用run_script方法目前作者没有找到解决的办法fromodpsimportODPS# 创建 ODPS 对象如果该脚本是在阿里云DataWorks上运行的下面4句可删了access_idyour-access-idaccess_keyyour-access-keyproject_nameyour-project-nameodpsODPS(access_id,access_key,project_name)# 指定脚本名称script_namemy_script# 定义参数params{param1:value1,param2:value2}# 调用 ODPS Scriptinstanceodps.run_script(script_name,paramsparams)instance.wait_for_success()# 获取查询结果withinstance.open_reader()asreader:forrecordinreader:print(record)2、python脚本调用执行sqlfromodpsimportODPS# 创建 ODPS 对象如果该脚本是在阿里云DataWorks上运行的下面4句可删了access_idyour-access-idaccess_keyyour-access-keyproject_nameyour-project-nameodpsODPS(access_id,access_key,project_name)# 定义参数param1value1param2value2# 动态构建 SQL 语句sqlfSELECT * FROM my_table WHERE column1 {param1} AND column2 {param2}# 执行 SQLinstanceodps.run_sql(sql)instance.wait_for_success()# 获取查询结果withinstance.open_reader()asreader:forrecordinreader:print(record) RELATED READING
延伸阅读
更多一线实战笔记与深度复盘，助您持续精进
![[光学原理与应用-521]：对光的错误理解与纠偏](http://pic.xiahunao.cn/yaotu/[光学原理与应用-521]：对光的错误理解与纠偏)
算法精解与面试技巧)
