使用NiFi将空间数据从Oracle(12+)导入HDFS

Question

当使用“sdo_util.to_wktgeometrige()”函数将数据类型转换为长字符串时，似乎不可能。对于第一个处理器，第二个处理器会出现错误：“sdo_util.to_wktgeometrion()非法字符”

有人有关于通过NIFI从Oracle(12+)迁移几何数据类型的技巧吗？一个线字符串就足够了几何图形对象的信息（就目前而言）

Answer 1

我想NiFi不知道如何处理关系数据库中定义的任何类型的对象。而对复杂类型如空间类型的理解显然要少得多。即使它确实理解对象类型，您也会遇到一些难以使用的问题，因为它会暴露类型的内部，您需要深入检查Oracle手册以解码内容才能使用这些信息。

最简单的方法无疑是以序列化字符串或二进制表示法获取空间类型。您可以在多个符号和两种获取这些符号的方法之间进行选择：

使用对象类型方法：

SQL> select c.location.get_wkt() from us_cities c where city='New York';

C.LOCATION.GET_WKT()
-------------------------------------------------------------------------------
POINT (-73.943849 40.6698)

1 row selected.

SQL> select c.location.get_gml() from us_cities c where city='New York';

C.LOCATION.GET_GML()
-------------------------------------------------------------------------------
<gml:Point srsName="EPSG:4326" xmlns:gml="http://www.opengis.net/gml"><gml:coordinates decimal="." cs="," ts=" ">-73.943849,40.6698 </gml:coordinates></gml:Point>

1 row selected.

SQL> select c.location.get_geojson() from us_cities c where city='New York';

C.LOCATION.GET_GEOJSON()
-------------------------------------------------------------------------------
{ "type": "Point", "coordinates": [-73.943849, 40.6698] }

1 row selected.

使用函数：

WKT

SQL> select sdo_util.to_wktgeometry(location) from us_cities c where city='New York';

SDO_UTIL.TO_WKTGEOMETRY(LOCATION)
-------------------------------------------------------------------------------
POINT (-73.943849 40.6698)

1 row selected.

GML

SQL> select sdo_util.to_gmlgeometry(location) from us_cities c where city='New York';

SDO_UTIL.TO_GMLGEOMETRY(LOCATION)
-------------------------------------------------------------------------------
<gml:Point srsName="EPSG:4326" xmlns:gml="http://www.opengis.net/gml"><gml:coordinates decimal="." cs="," ts=" ">-73.943849,40.6698 </gml:coordinates></gml:Point>

1 row selected.

SQL> select sdo_util.to_geojson(location) from us_cities c where city='New York';

SDO_UTIL.TO_GEOJSON(LOCATION)
-------------------------------------------------------------------------------
{ "type": "Point", "coordinates": [-73.943849, 40.6698] }

1 row selected.

select city, c.location.sdo_point.x longitude, c.location.sdo_point.y latitude 
from us_cities c;

CITY                            LONGITUDE   LATITUDE
------------------------------ ---------- ----------
New York                       -73.943849    40.6698
Los Angeles                     -118.4112  34.112101
....
Sioux Falls                      -96.7301  43.544201
Simi Valley                     -118.7513   34.26305

195 rows selected.