用Ganos低代码实现免切片遥感影像浏览(一)

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介: 本文介绍了使用PolarDB-PG数据库配合Ganos时空数据库引擎,不借助第三方工具仅利用SQL语句快速管理与展示遥感影像数据的一种方法。Ganos共提供两种影像免切浏览的方法,一种使用窗口范围获取影像数据展示,另一种通过固定瓦片范围获取影像数据展示,本文详细介绍第一种方法并提供了前后端实操代码帮助用户可以快速理解Ganos Raster的使用细节。

1. 引言

当我们管理着日益增长的遥感数据时,想要将任一影像展现在地图上往往要思考如下的问题:

  • 对于可能只使用几次的影像进行传统的切片、发布流程是否兴师动众?瓦片存储在何处?瓦片数据如何进行后续的管理?……
  • 不进行预切片而采用实时切片的方案能否满足前端的响应需求?遇到特别巨大的影像时,实时切片会受到多大影响?……

不过,如果你使用云原生关系型数据库PolarDB(兼容PostgreSQL版本)管理影像,可以利用Ganos Raster扩展,无需借助第三方工具,仅利用SQL语句,即可快速将库内影像高效的展现在地图上。

本文将按照如下顺序展开,介绍如何利用Ganos实现影像浏览功能 :

  1. 前期准备:将影像从OSS中导入PolarDB,并创建金字塔;
  2. 语句解析:了解如何从数据库中以图片格式提取遥感影像;
  3. 代码实践:使用Python语言编写一个简易的地图服务,配合Mapbox框架将数据库内的遥感影像展示在地图上。

2. 导入影像数据

在数据库内创建raster扩展。

CREATE EXTENSION ganos_raster CASCADE;


创建一张表raster_table,作为我们的测试表。

createtable raster_table (ID INT PRIMARY KEY NOTNULL,name text,rast raster);

接下来我们从OSS中导入一幅影像作为测试数据。

我们使用Ganos的ST_ImportFrom方法导入影像到分块表chunk_table,更详细的参数描述可以参考官方文档

insertinto raster_table values(1,'xxxx影像', ST_ImportFrom('chunk_table','OSS://ABCDEFG:1234567890@oss-cn.aliyuncs.com/mybucket/data/4.tif'));

3. 创建金字塔

金字塔是快速浏览影像数据的前提,对于新导入的数据,我们建议先创建金字塔。Ganos为我们提供了ST_BuildPyramid方法来创建金字塔。

方法原型如下,更详细的参数描述可以参考官方文档

raster ST_BuildPyramid(raster source,[cstring chunkTableName])

其中

  • source:需要创建金字塔的影像。
  • chunkTableName:金字塔所存储的分块表名称。
  • 该方法返回更新后的raster对象。

实际调用如下

update raster_table set rast = st_buildpyramid(raster_table,'chunk_table')where name ='xxxx影像';

我们为导入的测试数据创建了金字塔,存储于分块表chunk_table中,并使用Update方法更新了raster对象。

4. 从数据库内提取影像

创建好金字塔,我们就可以使用Ganos的ST_AsImage方法从数据库中获取指定范围的影像。

方法原型如下,更详细的参数描述可以参考官方文档

bytea ST_AsImage(raster raster_obj,                 box extent,integer pyramidLevel default0,                 cstring bands default'',                 cstring format default'PNG',                 cstring optiondefault'');

4.1 静态参数解析

静态参数指一般不随用户操作而变化的参数,我们可以在代码中固定它们:

  • bands:指定要显示的波段。
  • 待显示的波段列表,可以使用0-3或0,1,2,3等形式,不能超过影像本身的波段。
  • format:格式。
  • 默认为PNG格式,可选JPEG格式。由于PNG格式对数据的压缩效果不如JPEG格式的有损压缩,因此在传输时将耗费更多的时间,在没有透明度需求的情况下应尽量选择JPEG格式。
  • option:其他参数。
  • JSON字符串格式。可以定义额外的渲染参数。

4.2 动态参数解析

动态参数随用户操作而变化,需要动态生成它们:

  • extent:需要获取的影像范围。
  • 在条件一样的情况下,显示范围越大,数据库处理时间越长,返回图片的体积也越大,总体响应时间越长。
  • 因此最好只获取用户视域范围内的影像,以保证传输的效率。
  • pyramidLevel:使用的金字塔级别。
  • 使用的金字塔级别越高,图片越清晰,体积也就越大。
  • 因此需要选择最适宜的金字塔级别,以保证传输的效率。

4.2.1 获取影像外包框范围

使用Ganos的ST_Envelope方法可以获取到影像的外包框范围,并且使用ST_Transform方法将影像转换到常用的WGS 84坐标系下,最终将其转换为前端方便使用的格式。

实际调用如下

select replace((box2d(st_transform(st_envelope(geom),4326)))::text,'BOX','')from rat_clip where name ='xxxx影像'

4.2.2 获取最适宜金字塔级别

使用Ganos的ST_BestPyramidLevel方法可以计算特定影像范围内最适宜的金字塔级别。

方法原型如下,更详细的参数描述可以参考官方文档

integer ST_BestPyramidLevel(raster rast,                            Box extent,integer width,integer height )

其中

  • extent:可视区域所要获取的影像范围。
  • ST_AsImage方法中使用的范围一致。
  • width/height:可视区域的像素宽高。
  • 一般来说,这就是我们使用的前端地图框的尺寸。

值得一提的是,ST_BestPyramidLevelST_AsImage方法中使用的是原生的Box类型,而非Geometry兼容类型,因此需要将其转换。

我们约定,从前端传回的是BBox数组,要将其转换为原生Box类型需要如下步骤:

  1. 从前端传回的字符串在SQL语句中构建为Geometry类型对象。
  2. Geometry类型对象转换为Text类型对象。
  3. 使用文本替换方式将其转换为Box类型兼容格式的Text类型对象。
  4. Text类型对象转换为Box类型对象。

实际调用如下

select  Replace(Replace(Replace(box2d(st_transform(st_setsrid(ST_Multi(ST_Union(st_point(-180,-58.077876),st_point(180,58.077876))),4326),st_srid(rast)))::text,'BOX',''),',','),('),' ',',')::box from rat_clip where name ='xxxx影像';-- 返回 (180.0,58.077876),(-180.0,-58.077876)

注:Ganos在6.0版本(计划2023年11月下旬上线发布)会提供Raster Box类型与Geometry Box2d类型之间的转换函数,上述嵌套的replace操作可以通过调用::box进行类型转换后简化

5. 基于Ganos栅格能力的最佳实践

栅格数据的浏览一般可采用Geoserver发布服务的方式,Ganos同样也支持基于Geoserver的栅格/矢量服务发布,详情可参考官方文档本文介绍了一种更为简单的低代码方法,不需要依赖任何GIS Server工具,用最少的代码快速搭建一个能随用户对地图的拖拽与缩放,动态更新显示我们指定影像数据的地图应用,这种方式更便于业务系统集成,也方便用户理解Ganos栅格的相关能力。

5.1 整体结构

5.2 后端代码

为了代码简洁,更侧重于逻辑的描述,我们选择了Python作为后端语言,Web框架使用了基于Python的Flask框架,数据库连接框架使用了基于Python的Psycopg2(使用pip install psycopg2-binary进行安装)。

我们在后端实现了一个简易的地图服务,自动建立金字塔,响应前端请求返回指定范围内的影像数据。

# -*- coding: utf-8 -*-# @File : Raster.pyimportjsonfromflaskimportFlask, request, Response, send_from_directoryimportbinasciiimportpsycopg2# 连接参数CONNECTION="dbname=postgres user=postgres password=postgres host=YOUR_HOST port=5432"# 影像地址OSS_RASTER="OSS://ABCDEFG:1234567890@oss-cn.aliyuncs.com/mybucket/data/4.tif"# 分块表表名RASTER_NAME="xxxx影像"# 分块表表名CHUNK_TABLE="chunk_table"# 主表名RASTER_TABLE="raster_table"# 字段名RASTER_COLUMN="rast"# 默认渲染参数DEFAULT_CONFIG= {
"strength": "ratio",
"quality": 70}
classRasterViewer:
def__init__(self):
self.pg_connection=psycopg2.connect(CONNECTION)
self.column_name=RASTER_COLUMNself.table_name=RASTER_TABLEself._make_table()
self._import_raster(OSS_RASTER)
defpoll_query(self, query: str):
pg_cursor=self.pg_connection.cursor()
pg_cursor.execute(query)
record=pg_cursor.fetchone()
self.pg_connection.commit()
pg_cursor.close()
ifrecordisnotNone:
returnrecord[0]
defpoll_command(self, query: str):
pg_cursor=self.pg_connection.cursor()
pg_cursor.execute(query)
self.pg_connection.commit()
pg_cursor.close()
def_make_table(self):
sql=f"create table if not exists {self.table_name} (ID INT PRIMARY KEY NOT NULL,name text, {self.column_name} raster);"self.poll_command(sql)
def_import_raster(self, raster):
sql=f"insert into {self.table_name} values (1, '{RASTER_NAME}', ST_ComputeStatistics(st_buildpyramid(ST_ImportFrom('{CHUNK_TABLE}','{raster}'),'{CHUNK_TABLE}'))) on conflict (id) do nothing;;"self.poll_command(sql)
self.identify=f" name= '{RASTER_NAME}'"defget_extent(self) ->list:
"""获取影像范围"""importresql=f"select replace((box2d(st_transform(st_envelope({self.column_name}),4326)))::text,'BOX','') from {self.table_name} where {self.identify}"result=self.poll_query(sql)
# 转换为前端方便识别的形式bbox= [float(x) forxinre.split(
'\(|,|\s|\)', result) ifx!='']
returnbboxdefget_jpeg(self, bbox: list, width: int, height: int) ->bytes:
"""        获取指定位置的影像        :param bbox: 指定位置的外包框        :param width: 视区控件宽度        :param height: 视区控件高度        """# 指定波段和渲染参数bands="0-2"options=json.dumps(DEFAULT_CONFIG)
# 获取范围boxSQl=f"Replace(Replace(Replace(box2d(st_transform(st_setsrid(ST_Multi(ST_Union(st_point({bbox[0]},{bbox[1]}),st_point({bbox[2]},{bbox[3]}))),4326),st_srid({self.column_name})))::text, 'BOX', ''), ',', '),('),' ',',')::box"sql=f"select encode(ST_AsImage({self.column_name},{boxSQl} ,ST_BestPyramidLevel({self.column_name},{boxSQl},{width},{height}),'{bands}','jpeg','{options}'),'hex')  from {self.table_name} where {self.identify}"result=self.poll_query(sql)
result=binascii.a2b_hex(result)
returnresultrasterViewer=RasterViewer()
app=Flask(__name__)
@app.route('/raster/image')
defraster_image():
bbox=request.args['bbox'].split(',')
width=int(request.args['width'])
height=int(request.args['height'])
returnResponse(
response=rasterViewer.get_jpeg(bbox, width, height),
mimetype="image/jpeg"    )
@app.route('/raster/extent')
defraster_extent():
returnResponse(
response=json.dumps(rasterViewer.get_extent()),
mimetype="application/json",
    )
@app.route('/raster')
defraster_demo():
"""代理前端页面"""returnsend_from_directory("./", "Raster.html")
if__name__=="__main__":
app.run(port=5000, threaded=True)

将以上代码保存为Raster.py文件,执行python Raster.py命令即可启动服务。

5.3 后端代码解析

可以看出,针对影像数据,后端代码主要实现了3个功能:

  • 初始化数据:包括创建测试表,导入数据,建立金字塔并统计。
  • 获取影像位置:辅助前端地图快速定位影像,跳转到影像所在的位置。
  • 提取影像为图片格式:
  • 针对该影像,我们提前获取其元数据,知道该影像为3波段数据,当然也可以通过ST_NumBands方法动态获取其波段数。
  • 根据前端传回的范围信息和可视区域控件的像素宽高确定其范围。
  • 在使用psycopg2这个库时,以16进制传递数据的效率更高,如果使用其他框架,或者使用其他语言时,直接以二进制形式获取即可,无需编码转换。

在此我们使用Python作为示例代码,若使用其他语言,只要实现相同的逻辑,也能达到同样的效果。

5.4 前端代码

前端我们采用Mapbox作为地图框架,同时引入了Turf这个前端空间库,计算用户进行拖拽、缩放等地图操作后,当前视域与原始影像的交集,并向服务端请求该区域更清晰的图像,实现地图随操作更新影像的效果。

我们在后端代码的同一文件目录下新建名为Raster.html的文件,写入下列代码,在后端服务启动后,就可以通过http://localhost:5000/raster  访问。

<!DOCTYPE html><html><head><metacharset="UTF-8"/><title></title><linkhref="https://cdn.bootcdn.net/ajax/libs/mapbox-gl/1.13.0/mapbox-gl.min.css"rel="stylesheet"/></head><scriptsrc="https://cdn.bootcdn.net/ajax/libs/mapbox-gl/1.13.0/mapbox-gl.min.js"></script><scriptsrc="https://cdn.bootcdn.net/ajax/libs/axios/0.21.0/axios.min.js"></script><scriptsrc="https://cdn.bootcdn.net/ajax/libs/lodash.js/4.17.20/lodash.min.js"></script><scriptsrc="https://cdn.bootcdn.net/ajax/libs/Turf.js/5.1.6/turf.min.js"></script><body><divid="map"style="height: 100vh"/><script>// 初始化地图控件constmap=newmapboxgl.Map({
container: "map",
style: { version: 8, layers: [], sources: {} },
    });
classExtent {
constructor(geojson) {
// 默认使用Geojson格式this._extent=geojson;
      }
staticFromBBox(bbox) {
// 从BBOx格式生成Extent对象returnnewExtent(turf.bboxPolygon(bbox));
      }
staticFromBounds(bounds) {
// 从Mapbox的Bounds生成Extent对象constbbox= [
bounds._sw.lng,
bounds._sw.lat,
bounds._ne.lng,
bounds._ne.lat,
        ];
returnExtent.FromBBox(bbox);
      }
intersect(another) {
// 判断相交区域constinrersect=turf.intersect(this._extent, another._extent);
returninrersect?newExtent(inrersect) : null;
      }
toQuery() {
// 转换为query格式returnturf.bbox(this._extent).join(",");
      }
toBBox() {
// 转换为BBox格式returnturf.bbox(this._extent);
      }
toMapboxCoordinates() {
// 转换为Mapbox Coordinate格式constbbox=this.toBBox();
constcoordinates= [
          [bbox[0], bbox[3]],
          [bbox[2], bbox[3]],
          [bbox[2], bbox[1]],
          [bbox[0], bbox[1]],
        ];
returncoordinates;
      }
    }
map.on("load", async () => {
map.resize();
constlocation=window.location.href;
// 拼接查询语句constgetUrl= (extent) => {
constparams= {
bbox: extent.toQuery(),
height: map.getCanvas().height,
width: map.getCanvas().width,
        };
// 拼接请求体consturl=`${location}/image?${Object.keys(params)
          .map((key) =>`${key}=${params[key]}`)
          .join("&")}`;
returnurl;
      };
// 查询影像范围constresult=awaitaxios.get(`${location}/extent`);
constextent=Extent.FromBBox(result.data);
constcoordinates=extent.toMapboxCoordinates();
// 添加数据源map.addSource("raster_source", {
type: "image",
url: getUrl(extent),
coordinates,
      });
//添加图层//使用了Mapbox的image类型图层,采用将图片附着在指定位置上的方法,让影像在地图上展示map.addLayer({
id: "raster_layer",
paint: { "raster-fade-duration": 300 },
type: "raster",
layout: { visibility: "visible" },
source: "raster_source",
      });
// 跳转到影像位置map.fitBounds(extent.toBBox());
// 绑定刷新方法map.once("moveend", () => {
constupdateRaster= () => {
const_extent=Extent.FromBounds(map.getBounds());
letintersect;
// 当可视区域没有图形时不重新请求if (!_extent||!(intersect=extent.intersect(_extent))) return;
// 更新图形map.getSource("raster_source").updateImage({
url: getUrl(intersect),
coordinates: intersect.toMapboxCoordinates(),
          });
        };
// 添加防抖,减少无效请求const_updateRaster=_.debounce(updateRaster, 200);
map.on("zoomend", _updateRaster);
map.on("moveend", _updateRaster);
      });
    });
</script></body></html>

5.5 前端代码解析

由于我们的影像获取接口不是一个标准地图协议接口,因此需要手动实现与影像更新相关的功能。

我们要解决的最大问题是:如何确定用户视域范围内的影像范围。

解决的基本逻辑为:

  1. 获取影像的空间范围。
  2. 获取用户当前视域的空间范围。
  3. 获取两者的交集,即为预期的影像范围。

为了在前端实现预定的空间判断功能,我们引入了Turf框架,将简单的计算在前端实现,减少不必要的请求次数。

为了方便空间判断与各种格式间转换,我们还实现了一个辅助类Extent,包括如下功能:

  • 格式互转:
  • BBox <=> Geojson
  • Mapbox Coordinate <=> Geojson
  • Geojson => Query
  • Bounds => Geojson
  • 封装了Turf的空间判断方法。

6. 效果

6.1 数据总览效果

6.2 在PGAdmin中集成影像浏览功能

可以将影像浏览功能集成在兼容PolarDB的数据库客户端软件PGAdmin中,这样即可快速浏览库内的影像数据,评估数据概况,增强数据管理的使用体验。

7. 总结

本文介绍了如何利用Ganos Raster的相关方法实现提取库内影像数据的功能,并最终通过少量代码实现了一个可交互浏览库内遥感影像的地图应用。

从本实践中我们可以看到,使用Ganos管理日益增长的遥感影像,不仅可以降低管理成本,还可以通过Ganos Raster扩展,不借助第三方复杂工具,使用少量代码即可直接浏览库内影像数据,大大增强了数据管理的体验。

相关实践学习
Serverless极速搭建Hexo博客
本场景介绍如何使用阿里云函数计算服务命令行工具快速搭建一个Hexo博客。
相关文章
|
数据可视化 定位技术 API
百度地图开发:海量点、测距以及定位聚合功能
百度地图开发:海量点、测距以及定位聚合功能
306 0
|
2月前
|
SQL 关系型数据库 分布式数据库
用Ganos低代码实现免切片遥感影像浏览
本文介绍了一种基于PolarDB兼容PostgreSQL 14的高效栅格数据管理和可视化方案。推荐配置包括4核CPU、16GB内存、50GB磁盘等。通过创建扩展并上传影像至OSS,利用SQL语句完成数据导入、镶嵌、匀色及金字塔构建。重点介绍了使用ST_AsTile函数动态生成标准瓦片的方法,支持多种格式和增强方式。前端通过Python实现服务接口,实现实时、高效的数据展示。此方案具有实时性强、存储成本低等优点,适合快速可视化大量栅格数据。
42 0
|
6月前
|
存储 数据可视化 Cloud Native
用Ganos低代码实现免切片遥感影像浏览(二):动态栅格瓦片
本文介绍了Ganos全新发布了动态栅格瓦片能力,帮助用户将库内栅格数据或栅格分析结果快速可视化,无需依赖类似GeoServer等空间服务中间件,技术栈短平快,使用灵活高效。
|
数据可视化 定位技术
GIS空间分析 数字地形分析1 地势图的制作
在本文中,你将学到如何根据DEM数据制作地势图
142 0
|
6月前
|
定位技术 Python
ArcGIS批量拼接大量栅格遥感影像:Mosaic工具
ArcGIS批量拼接大量栅格遥感影像:Mosaic工具
240 1
|
6月前
|
存储 定位技术 Python
Python中ArcPy实现对不同时相的栅格遥感影像依据其成像时间分别批量拼接
Python中ArcPy实现对不同时相的栅格遥感影像依据其成像时间分别批量拼接
|
6月前
|
数据可视化 定位技术
Tableau可视化设计案例-06Tableau填充地图,多维地图,混合地图
Tableau可视化设计案例-06Tableau填充地图,多维地图,混合地图
|
11月前
|
数据可视化 Java 关系型数据库
智慧工厂高精度定位系统源码,支持零维、一维、二维定位方式
电子巡检 可提前为标签预设巡检任务,包括巡检时间/路线/名称。一旦巡检人员未按规定的时间/路线巡查,系统将立即报警。 人员管理 可以提前将人员的详细数据(如姓名、职务ID) 输入到系统中,并与标签ID绑定。 角色管理
|
存储 Cloud Native 关系型数据库
Ganos矢量栅格数据快速入库方法简介
本文介绍了Ganos提供的矢量、栅格数据高效入库方法,帮助用户快速理解云原生数据库空间数据的写入方案,以便更好的使用Ganos矢栅数据的处理能力。
|
存储 SQL 数据可视化
Ganos三维引擎系列(一):倾斜摄影数据管理与可视化功能解析
本文介绍了阿里云多模态时空数据库Ganos三维引擎在倾斜摄影数据管理中的应用。Ganos三维引擎支持三大类存储结构:表面网格模型、体网格模型与3D实景模型,其中表面网格模型用于存储带有语义的类BIM精细化三维模型,体网格模型用于存储地质体等非匀质“场”类三维模型,3D实景模型用于存储倾斜摄影、精白模等用于渲染的三维模型,三种存储结构都提供了原生数据类型、空间索引、分析算子、导入导出工具、可视化支撑等功能,为数字孪生类应用提供闭环的存算显能力,本文重点介绍基于3D实景模型开展倾斜摄影数据管理与可视化等功能。