MaxComputer——pyodps

Posted 2022-06-14 jiangbei

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))