0
点赞
收藏
分享

微信扫一扫

PythonNote015---Python和odps交互

心智的年轮 2022-08-04 阅读 61


python连接odps,并且通过sql进行查询,返回dataframe

from odps import ODPS
from odps import DataFrame
def exe_odps(sql, project):
'''
sql:待执行sql
project:项目空间
'''
access_id = '*****'
secret_access_key = '*****'
project = project
endpoint = 'http://service.odps.aliyun.com/api'
o = ODPS(
access_id=access_id,
secret_access_key=secret_access_key,
project=project,
endpoint=endpoint)
with o.execute_sql(sql).open_reader() as reader:
data = reader.to_pandas()
return data

                        2020-02-17 南京市栖霞区


举报

相关推荐

0 条评论