MaxComputer——pyodps

Posted jiangbei

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了MaxComputer——pyodps相关的知识,希望对你有一定的参考价值。

1.文档

  详细文档:https://pyodps.readthedocs.io/zh_CN/latest/base-projects.html

  官方文档:https://help.aliyun.com/document_detail/90412.html?spm=a2c4g.11174283.6.779.690b590ercWTA2

2.入门示例:

  1.获取表结构:

    

import sys;
# 防止中文注释乱码
reload(sys);
sys.setdefaultencoding("utf8")

# 定义表名筛选的前后缀
ODS_PREFIX = ods_
ODS_SUFFIX = _snapshot

ods_table_list = o.list_tables(project=rkk, prefix=ODS_PREFIX)
for t in ods_table_list:
    table_name = t.name
    if table_name.endswith(ODS_SUFFIX):
        # 获取表注释
        table_comment = t.comment
        cols = t.schema.columns
        for col in cols:
            col_name = col.name
            col_type = col.type
            col_comment = col.comment
            # 将表结构写入结果表
            o.execute_sql("insert into table rkk_ods_schema_all values (‘%s‘,‘%s‘,‘%s‘,‘%s‘,‘%s‘);" % (table_name,table_comment,col_name,col_type,col_comment))

  2.批量修改表注释

import sys;
# 防止中文注释乱码
reload(sys);
sys.setdefaultencoding("utf8")

# 需要修改表的表名
table_list = o.list_tables(prefix=ods_)
for t in table_list:
    table_name = t.name
    # 获取表注释
    old_std_comment = t.comment
    new_std_comment = "ods_" + old_std_comment
    # 非std_开头的注释,使用SQL DDL添加新注释
    if not old_std_comment.startswith(ods_):
        o.execute_sql("alter table %s set comment ‘%s‘;" % (table_name, new_std_comment))

 

以上是关于MaxComputer——pyodps的主要内容,如果未能解决你的问题,请参考以下文章

阿里云MaxComputer SQL学习之内置函数

dataWorks定时调度传参

dataWorks定时调度传参

SQLMaxComputer开发工具——DataWorks使用小结

阿里云DataWorks介绍

阿里云Quick BI理论学习