码迷,mamicode.com
首页 > 其他好文 > 详细

MaxComputer——pyodps

时间:2019-08-06 11:00:32      阅读:191      评论:0      收藏:0      [点我收藏+]

标签:中文   ase   value   font   snapshot   乱码   efi   tab   column   

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

标签:中文   ase   value   font   snapshot   乱码   efi   tab   column   

原文地址:https://www.cnblogs.com/jiangbei/p/11307371.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!