import sys
from odps import ODPS
reload(sys)
print('dt=' + args['dt'])
#修改系统默认编码。
sys.setdefaultencoding('utf8')
#个人信息凭证。
t = o.get_table('user_detail')
#获取分区表。
print t.exist_partition('dt=20190715,region=beijing')
#查看所有分区。
for partition in t.partitions:
print partition.name
#您可以通过以下三种方式查询分区表数据。
#第一种方式如下。
with t.open_reader(partition='dt=20190715,region=beijing') as reader1:
count = reader1.count
print("第一种方式查询分区表数据:")
for record in reader1:
print record[0],record[1],record[2]
#第二种方式如下。
print("第二种方式查询分区表数据:")
reader2 = t.open_reader(partition='dt=20190715,region=beijing')
for record in reader2:
print record["userid"],record["job"],record["education"]
#第三种方式如下。
print("第三种方式查询分表数据:")
for record in o.read_table('user_detail', partition='dt=20190715,region=beijing'):
print record["userid"],record["job"],record["education"]