DataWorks PyODPS execute_sql DataFrame?
在 DataWorks 中,PyODPS 的 execute_sql 方法可以用于执行 SQL 语句并返回 DataFrame 对象。以下是使用 execute_sql 方法执行 SQL 语句并返回 DataFrame 对象的示例:
import dataworks_pyodps as odps
df = odps.DataFrame([['col1', 'col2'], ['a', 'b']])
result = odps.execute_sql(
'SELECT * FROM {}'.format(df.name)
)
执行上述代码后,会返回一个 DataFrame 对象,包含以下内容:
col1 col2
a b
PyODPS 的 execute_sql 方法可以接受多个参数。除了 SQL 语句之外,还可以指定以下参数:
job_id: 指定任务的 ID。如果未指定,则会创建一个新的任务。
output_path: 指定输出数据的路径。如果未指定,则会将输出数据保存到当前工作目录。
parameters: 指定额外的参数。
更多关于 execute_sql 方法的使用方法,请参考 官方文档.
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎,为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。