请教下大数据计算MaxCompute,pyodps 提交sql的方式除了 execute_sql()/run_sql() 还有别的方式吗。我提交
--归档ds为20170101的数据
alter table my_log partition(ds='20170101') archive; 归档sql 报错?
除了execute_sql()
和run_sql()
,您还可以使用pyodps.DataFrame
对象来执行SQL查询。以下是一个示例:
from pyodps import ODPS
# 初始化ODPS对象
access_id = 'your_access_id'
access_key = 'your_access_key'
project = 'your_project'
endpoint = 'your_endpoint'
odps = ODPS(access_id, access_key, project, endpoint)
# 创建表对象
table = odps.get_table('my_log')
# 执行SQL查询
with table.open_reader() as reader:
for row in reader:
print(row)
关于归档SQL报错的问题,您可以尝试将归档操作放在一个单独的SQL语句中执行,如下所示:
-- 归档ds为20170101的数据
ALTER TABLE my_log PARTITION(ds='20170101') ARCHIVE;
然后在Python代码中使用pyodps.SQL
对象执行这个SQL语句:
from pyodps import SQL
# 初始化ODPS对象
access_id = 'your_access_id'
access_key = 'your_access_key'
project = 'your_project'
endpoint = 'your_endpoint'
odps = ODPS(access_id, access_key, project, endpoint)
# 创建SQL对象
sql = SQL("ALTER TABLE my_log PARTITION(ds='20170101') ARCHIVE;")
# 执行SQL语句
with odps.execute_sql(sql) as result:
print(result)
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
MaxCompute(原ODPS)是一项面向分析的大数据计算服务,它以Serverless架构提供快速、全托管的在线数据仓库服务,消除传统数据平台在资源扩展性和弹性方面的限制,最小化用户运维投入,使您经济并高效的分析处理海量数据。