本文共 652 字，大约阅读时间需要 2 分钟。

1. .在python编译器中写python文件（本次操作是处理电话号码的数据混乱问题）:

import sysfor line in sys.stdin:     for word in line:                if ord(word)<48 or ord(word)>57:                        line=line.replace(word,'')     if len(line)==12:          line=line[1:12]    else:          line=line[0:11]         print(line)

2. 然后，在FZ中操作本地文件到hive的环境中
   
   3.在对应的环境中添加python文件到hdfs：
   

hadoop fs -put /home/hive/data/delete_not_number1.py hdfs://yilihdptest/tmp/delete_not_number1.py

4. 调用hdfs中的python 文件：

add file hdfs://yilihdptest/tmp/delete_not_number1.py;selectTRANSFORM (exchgOrder.TeleNum)USING 'python delete_not_number1.py'  AS (rcv_tele)FROM sdata_full.CRM_PNT_ExchangeOrder exchgOrder

转载地址：http://jpoen.baihongyu.com/