Skip to content
Hive UDF, 实现 ip 转地理位置
Python
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
.gitignore add git ignore Jan 17, 2019
README.md fix Jan 17, 2019
ip2Region.py ip 转地理位置 hive udf Jan 17, 2019
ip2area.py
ip2region.db ip 转地理位置 hive udf Jan 17, 2019

README.md

udf-ip2region

Hive UDF, 实现 ip 转地理位置

简介

  • ip2region.db: 数据库来源:https://github.com/lionsoul2014/ip2region 该地址会定时更新,可设置定时更新此数据库文件。

  • ip2Region.py: 为官方类,主要实现 db 文件数据查询。

  • ip2area.py: 为 hive 需要调用的脚本。

添加脚本到 hive

add file /data/hive-pyhton-udf/udf-ip2region/ip2region.db /data/hive-pyhton-udf/udf-ip2region/ip2Region.py /data/hive-pyhton-udf/udf-ip2region/ip2area.py;

Hive 中使用

select TRANSFORM(ip) USING "python ip2area.py" as (ip,country,province,city,isp) from  ( select '127.0.222.1' as ip ) t;
You can’t perform that action at this time.