OpenSeaMap-dev Diskussion:Downloadable Raster Charts: Unterschied zwischen den Versionen
Kannix (Diskussion | Beiträge) (→py script: update) |
Kannix (Diskussion | Beiträge) (→py script: ready 4 reviews) |
||
| Zeile 52: | Zeile 52: | ||
import math | import math | ||
from landez import MBTilesBuilder, ImageExporter, TilesManager | from landez import MBTilesBuilder, ImageExporter, TilesManager | ||
| + | import sqlite3 | ||
| + | import os | ||
| + | import sys | ||
logging.basicConfig(level=logging.DEBUG) | logging.basicConfig(level=logging.DEBUG) | ||
| Zeile 57: | Zeile 60: | ||
# to be imported from sqlite-queue | # to be imported from sqlite-queue | ||
| − | + | con = sqlite3.connect('queue.sqlite') | |
| − | + | ||
| − | + | with con: | |
| − | + | ||
| − | + | con.row_factory = sqlite3.Row | |
| − | sqChart = " | + | |
| − | sqName = " | + | cur = con.cursor() |
| − | sqHO = " | + | cur.execute('SELECT * FROM jobs WHERE status="open" ORDER BY microtime DESC') |
| − | + | ||
| + | rows = cur.fetchall() | ||
| + | |||
| + | for row in rows: | ||
| + | sqMicrotime = row["Microtime"] | ||
| + | sqChart = row["Chart"] | ||
| + | sqName = row["Name"] | ||
| + | sqHO = row["HO"] | ||
| + | sqBottomGeoPre = row["BottomGeoPre"] | ||
| + | sqTopGeoPre = row["TopGeoPre"] | ||
| + | sqLeftGeoPre = row["LeftGeoPre"] | ||
| + | sqRightGeoPre = row["RightGeoPre"] | ||
| + | sqNumTiles16 = row["NumTiles16"] | ||
# to be calculated from numtiles16, numtiles < 700 | # to be calculated from numtiles16, numtiles < 700 | ||
| Zeile 73: | Zeile 88: | ||
myZoom = 18 | myZoom = 18 | ||
| − | while (myNumTiles > | + | while (myNumTiles > 4): |
myNumTiles = myNumTiles / 4 | myNumTiles = myNumTiles / 4 | ||
myZoom = myZoom - 1 | myZoom = myZoom - 1 | ||
| Zeile 84: | Zeile 99: | ||
if sqHO == "DE": | if sqHO == "DE": | ||
myUrlHydro = "http://tiles.grade.de/tiles.py/NAUTHIS_SkinOfEarth/{z}/{x}/{y}.png" | myUrlHydro = "http://tiles.grade.de/tiles.py/NAUTHIS_SkinOfEarth/{z}/{x}/{y}.png" | ||
| + | |||
elif sqHO== "NL/GB": | elif sqHO== "NL/GB": | ||
myUrlHydro = "http://tiles.grade.de/tiles.py/ncp_diepte14/{z}/{x}/{y}.png" | myUrlHydro = "http://tiles.grade.de/tiles.py/ncp_diepte14/{z}/{x}/{y}.png" | ||
| Zeile 89: | Zeile 105: | ||
myUrlHydro = "" | myUrlHydro = "" | ||
| − | myFileName = | + | myFileName = str(sqMicrotime) |
myMbtilesFile = myFileName + ".mbtiles" | myMbtilesFile = myFileName + ".mbtiles" | ||
myImageFile = myFileName + ".jpg" | myImageFile = myFileName + ".jpg" | ||
| Zeile 182: | Zeile 198: | ||
logging.debug(" top: " + str(sqTopGeoPost)) | logging.debug(" top: " + str(sqTopGeoPost)) | ||
logging.debug(" bottom: " + str(sqBottomGeoPost)) | logging.debug(" bottom: " + str(sqBottomGeoPost)) | ||
| + | |||
| + | sqPost = [ | ||
| + | 'UrlBase="' + str(myUrlBase) + '"', | ||
| + | 'UrlSeamark="' + str(myUrlSeamark) + '"', | ||
| + | 'UrlHydro="' + str(myUrlHydro) + '"', | ||
| + | 'Zoom=' + str(myZoom), | ||
| + | 'BottomGeoPost='+ str(sqBottomGeoPost), | ||
| + | 'TopGeoPost='+ str(sqTopGeoPost), | ||
| + | 'LeftGeoPost='+ str(sqLeftGeoPost), | ||
| + | 'RightGeoPost='+ str(sqRightGeoPost), | ||
| + | 'status="done"' | ||
| + | ] | ||
| + | t = ", " | ||
| + | sqPost = t.join(sqPost) | ||
| + | sqlUpdate = "UPDATE jobs " + "SET " + str(sqPost) + " WHERE Microtime=" + str(sqMicrotime) | ||
| + | logging.debug(" sqlUpdate: " + str(sqlUpdate)) | ||
| + | |||
| + | con = sqlite3.connect('queue.sqlite') | ||
| + | with con: | ||
| + | con.row_factory = sqlite3.Row | ||
| + | cur = con.cursor() | ||
| + | cur.execute(sqlUpdate) | ||
| + | con.commit() | ||
| + | logging.debug(" Number of rows updated: " + str(cur.rowcount)) | ||
# start imgkap to generate .kap file | # start imgkap to generate .kap file | ||
| Zeile 188: | Zeile 228: | ||
print myImgkapCall | print myImgkapCall | ||
subprocess.call(myImgkapCall, shell=True) | subprocess.call(myImgkapCall, shell=True) | ||
| + | |||
| + | # write textfile | ||
| + | txtPost = [ | ||
| + | 'INT Chart Number= ' + sqChart, | ||
| + | 'INT Chart Name= ' + sqName, | ||
| + | '', | ||
| + | 'Copyright Notices:', | ||
| + | 'Base Layer= http://developer.mapquest.com/de/web/products/open/map', | ||
| + | 'Seamark Layer= http://www.openseamap.org/', | ||
| + | 'DE Hydrography= http://gdiwiki.bsh.de/wiki/index.php/NAUTHIS_Skin_Of_The_Earth', | ||
| + | 'NL Hydrography= http://www.rijkswaterstaat.nl/zakelijk/databestanden/online_geografische_gegevens_rijkswaterstaat/', | ||
| + | '', | ||
| + | 'Zoom Level= ' + str(myZoom), | ||
| + | '', | ||
| + | 'Bottom= '+ str(sqBottomGeoPost), | ||
| + | 'Top= '+ str(sqTopGeoPost), | ||
| + | 'Left= '+ str(sqLeftGeoPost), | ||
| + | 'Right= '+ str(sqRightGeoPost), | ||
| + | '', | ||
| + | 'width= ' + str(sqWidth) + ' tiles', | ||
| + | 'height= ' + str(sqHeight) + ' tiles', | ||
| + | 'width= ' + str(sqWidthPix) + ' pixel', | ||
| + | 'height= ' + str(sqHeightPix) + ' pixel', | ||
| + | '', | ||
| + | 'left tile number= ' + str(sqLeftTile), | ||
| + | 'right tile number= ' + str(sqRightTile), | ||
| + | 'top tile number= ' + str(sqTopTile), | ||
| + | 'bottom tile number= '+ str(sqBottomTile) | ||
| + | ] | ||
| + | t = "\n" | ||
| + | txtPost = t.join(txtPost) | ||
| + | logging.debug(" txtPost: " + str(txtPost)) | ||
| + | |||
| + | with open(myTextFile, 'w') as f: | ||
| + | f.write(txtPost) | ||
| + | |||
| + | # move and rename files | ||
| + | myPath = "../INT-CHART/INT-" | ||
| + | myNotice = "_MapQuest-OSeaM-BSH" | ||
| + | |||
| + | myNewMbtilesFile = myPath + sqChart + myNotice + ".mbtiles" | ||
| + | myNewImageFile = myPath + sqChart + myNotice + ".jpg" | ||
| + | myNewKapFile = myPath + sqChart + myNotice + ".kap" | ||
| + | myNewTextFile = myPath + sqChart + myNotice + ".txt" | ||
| + | |||
| + | try: | ||
| + | os.rename (myMbtilesFile, myNewMbtilesFile) | ||
| + | os.remove(myMbtilesFile) | ||
| + | except OSError: | ||
| + | pass | ||
| + | |||
| + | try: | ||
| + | os.rename (myImageFile, myNewImageFile) | ||
| + | os.remove(myImageFile) | ||
| + | except OSError: | ||
| + | pass | ||
| + | |||
| + | try: | ||
| + | os.rename (myKapFile, myNewKapFile) | ||
| + | os.remove(myKapFile) | ||
| + | except OSError: | ||
| + | pass | ||
| + | |||
| + | try: | ||
| + | os.rename (myTextFile, myNewTextFile) | ||
| + | os.remove(myTextFile) | ||
| + | except OSError: | ||
| + | pass | ||
Version vom 12. Februar 2015, 18:54 Uhr
Inhaltsverzeichnis
ideas
web frontend
- die INT-chart Grenzen (als Basis fuer ein download-tool) bekomme ich inzwischen auf den Schirm: http://kap.grade.de/int-chart-ol2.html , sicherlich verbesserungsbeduerftig
- workflow
- INT-Chart durch klick auf die Karte waehlen
- download iniziieren
- Weiterleitung auf neue Seite
- pruefen, ob und in welchem Format vorhanden
- wenn ja und nicht zu alt, downloadlinks anbieten
- wenn nein Job in queue-db schreiben
- number, name, bbox, scale, sessionid, ip-address, email, microtime, status=open, ...
- das ganze garnieren mit
- Pruefung, ob das script fuer diese karte schon in der Warteschlange ist
- Limitierung auf x downloads/jobs pro session ...
- email notifier
- captcha
prerequisites
- apache
- php
- sqlite
tile server
- cronjob checkt queue-db alle x Minuten
- waehlt aeltesten job aus queue-db mit status=open
- tiledownload ueber proxy mit landez
- sinnvolles zoom-level anhand bbox errechnen (max. 10MB/chart)
- mbtiles erzeugen (siehe auch mbtiles implementation)
- stitchen und .png/.jpg erzeugen
- .kap mit imgkap erstellen
- ...
- status=done, zoom-level, date, ... in queue-db setzen
- temp-dir bereinigen und results in charts-dir kopieren
prerequisites
py script
- relies on landez
import logging
import shutil
import math
from landez import MBTilesBuilder, ImageExporter, TilesManager
import sqlite3
import os
import sys
logging.basicConfig(level=logging.DEBUG)
# to be imported from sqlite-queue
con = sqlite3.connect('queue.sqlite')
with con:
con.row_factory = sqlite3.Row
cur = con.cursor()
cur.execute('SELECT * FROM jobs WHERE status="open" ORDER BY microtime DESC')
rows = cur.fetchall()
for row in rows:
sqMicrotime = row["Microtime"]
sqChart = row["Chart"]
sqName = row["Name"]
sqHO = row["HO"]
sqBottomGeoPre = row["BottomGeoPre"]
sqTopGeoPre = row["TopGeoPre"]
sqLeftGeoPre = row["LeftGeoPre"]
sqRightGeoPre = row["RightGeoPre"]
sqNumTiles16 = row["NumTiles16"]
# to be calculated from numtiles16, numtiles < 700
# numtiles16 is right now hardcoded at int-chart.gejson for ol depth of view reasons, there might be smarter ways in future
# https://github.com/makinacorpus/landez/issues/44
myNumTiles = sqNumTiles16 * 4 * 4
myZoom = 18
while (myNumTiles > 4):
myNumTiles = myNumTiles / 4
myZoom = myZoom - 1
# settings
# myUrlBase = "http://tiles.grade.de/tiles.py/openriverboatmap/{z}/{x}/{y}.png"
myUrlBase = "http://otile1.mqcdn.com/tiles/1.0.0/map/{z}/{x}/{y}.jpg"
myUrlSeamark = "http://tiles.grade.de/tiles.py/seamark/{z}/{x}/{y}.png"
if sqHO == "DE":
myUrlHydro = "http://tiles.grade.de/tiles.py/NAUTHIS_SkinOfEarth/{z}/{x}/{y}.png"
elif sqHO== "NL/GB":
myUrlHydro = "http://tiles.grade.de/tiles.py/ncp_diepte14/{z}/{x}/{y}.png"
else:
myUrlHydro = ""
myFileName = str(sqMicrotime)
myMbtilesFile = myFileName + ".mbtiles"
myImageFile = myFileName + ".jpg"
myKapFile = myFileName + ".kap"
myTextFile = myFileName + ".txt"
myBbox = (sqLeftGeoPre, sqBottomGeoPre, sqRightGeoPre, sqTopGeoPre)
myZoomLevels = [myZoom]
myZoomLevel = myZoom
myTileSize = 256
#myTileFormat = 'image/png'
myTileFormat = 'image/jpeg'
# download and mbtiles build
mb = MBTilesBuilder(tiles_url=myUrlBase, cache=True, filepath=myMbtilesFile, tile_size=myTileSize, tile_format=myTileFormat)
mb.add_coverage(myBbox, myZoomLevels)
if myUrlHydro != "":
hydro = TilesManager(tiles_url=myUrlHydro)
seamark = TilesManager(tiles_url=myUrlSeamark)
hydro.add_layer(seamark)
overlay = hydro
else:
seamark = TilesManager(tiles_url=myUrlSeamark)
overlay = seamark
mb.add_layer(overlay)
mb.run(force=True)
# export image from mbtiles
# not the best idea: causes IO at temp dir, again
ie = ImageExporter(mbtiles_file=myMbtilesFile)
ie.export_image(myBbox, myZoomLevel, imagepath=myImageFile)
# save the geoinfo
myGrid = ie.grid_tiles(myBbox, myZoomLevel)
sqWidth = len(myGrid[0])
sqHeight = len(myGrid)
sqWidthPix = sqWidth * myTileSize
sqHeightPix = sqHeight * myTileSize
# delete temp dir (ImageExporter does not!)
# bad: path is hard coded. how do I get hold of landez's temp path?
# https://github.com/makinacorpus/landez/issues/42
try:
shutil.rmtree('/tmp/landez')
except OSError:
pass
# geoinfo output
logging.debug(" grid: " + str(myGrid))
myLeftColumn = myGrid[0]
myTopLeft = myLeftColumn[0]
sqLeftTile = myTopLeft[0]
sqTopTile = myTopLeft[-1]
myRightColumn = myGrid[-1]
myBottomRight = myRightColumn[-1]
sqRightTile = myBottomRight[0]
sqBottomTile = myBottomRight[-1]
# calculate coords from tilenumbers
def num2deg(xtile, ytile, zoom):
n = 2.0 ** zoom
lon_deg = -180.0 + 360.0 * xtile / n
lat_rad = math.atan(math.sinh(math.pi * (1.0 - 2.0 * (ytile / n))))
lat_deg = 180.0 * lat_rad / math.pi
return (lon_deg, lat_deg)
sqBottomGeoPost = (num2deg(sqRightTile + 1, sqBottomTile + 1, myZoom)[-1])
sqTopGeoPost = (num2deg(sqLeftTile, sqTopTile, myZoom)[-1])
sqLeftGeoPost = (num2deg(sqLeftTile, sqTopTile, myZoom)[0])
sqRightGeoPost = (num2deg(sqRightTile + 1, sqBottomTile + 1, myZoom)[0])
# shall be exported to sqlite-queue
logging.debug(" baselayer: " + str(myUrlBase))
logging.debug(" seamark: " + str(myUrlSeamark))
logging.debug(" hydro: " + str(myUrlHydro))
logging.debug(" zoom: " + str(myZoom))
logging.debug(" width: " + str(sqWidth) + " tiles")
logging.debug(" height: " + str(sqHeight) + " tiles")
logging.debug(" widthpix: " + str(sqWidthPix) + " pixel")
logging.debug(" heightpix: "+ str(sqHeightPix) + " pixel")
logging.debug(" left tile " + str(sqLeftTile))
logging.debug(" right tile: " + str(sqRightTile))
logging.debug(" top tile: " + str(sqTopTile))
logging.debug(" bottom tile: "+ str(sqBottomTile))
logging.debug(" left: " + str(sqLeftGeoPost))
logging.debug(" right: " + str(sqRightGeoPost))
logging.debug(" top: " + str(sqTopGeoPost))
logging.debug(" bottom: " + str(sqBottomGeoPost))
sqPost = [
'UrlBase="' + str(myUrlBase) + '"',
'UrlSeamark="' + str(myUrlSeamark) + '"',
'UrlHydro="' + str(myUrlHydro) + '"',
'Zoom=' + str(myZoom),
'BottomGeoPost='+ str(sqBottomGeoPost),
'TopGeoPost='+ str(sqTopGeoPost),
'LeftGeoPost='+ str(sqLeftGeoPost),
'RightGeoPost='+ str(sqRightGeoPost),
'status="done"'
]
t = ", "
sqPost = t.join(sqPost)
sqlUpdate = "UPDATE jobs " + "SET " + str(sqPost) + " WHERE Microtime=" + str(sqMicrotime)
logging.debug(" sqlUpdate: " + str(sqlUpdate))
con = sqlite3.connect('queue.sqlite')
with con:
con.row_factory = sqlite3.Row
cur = con.cursor()
cur.execute(sqlUpdate)
con.commit()
logging.debug(" Number of rows updated: " + str(cur.rowcount))
# start imgkap to generate .kap file
import subprocess
myImgkapCall = "./imgkap " + myImageFile + " " + str(sqTopGeoPost) + " " + str(sqLeftGeoPost) + " " + str(sqBottomGeoPost) + " " + str(sqRightGeoPost) + " " + myKapFile
print myImgkapCall
subprocess.call(myImgkapCall, shell=True)
# write textfile
txtPost = [
'INT Chart Number= ' + sqChart,
'INT Chart Name= ' + sqName,
'',
'Copyright Notices:',
'Base Layer= http://developer.mapquest.com/de/web/products/open/map',
'Seamark Layer= http://www.openseamap.org/',
'DE Hydrography= http://gdiwiki.bsh.de/wiki/index.php/NAUTHIS_Skin_Of_The_Earth',
'NL Hydrography= http://www.rijkswaterstaat.nl/zakelijk/databestanden/online_geografische_gegevens_rijkswaterstaat/',
'',
'Zoom Level= ' + str(myZoom),
'',
'Bottom= '+ str(sqBottomGeoPost),
'Top= '+ str(sqTopGeoPost),
'Left= '+ str(sqLeftGeoPost),
'Right= '+ str(sqRightGeoPost),
'',
'width= ' + str(sqWidth) + ' tiles',
'height= ' + str(sqHeight) + ' tiles',
'width= ' + str(sqWidthPix) + ' pixel',
'height= ' + str(sqHeightPix) + ' pixel',
'',
'left tile number= ' + str(sqLeftTile),
'right tile number= ' + str(sqRightTile),
'top tile number= ' + str(sqTopTile),
'bottom tile number= '+ str(sqBottomTile)
]
t = "\n"
txtPost = t.join(txtPost)
logging.debug(" txtPost: " + str(txtPost))
with open(myTextFile, 'w') as f:
f.write(txtPost)
# move and rename files
myPath = "../INT-CHART/INT-"
myNotice = "_MapQuest-OSeaM-BSH"
myNewMbtilesFile = myPath + sqChart + myNotice + ".mbtiles"
myNewImageFile = myPath + sqChart + myNotice + ".jpg"
myNewKapFile = myPath + sqChart + myNotice + ".kap"
myNewTextFile = myPath + sqChart + myNotice + ".txt"
try:
os.rename (myMbtilesFile, myNewMbtilesFile)
os.remove(myMbtilesFile)
except OSError:
pass
try:
os.rename (myImageFile, myNewImageFile)
os.remove(myImageFile)
except OSError:
pass
try:
os.rename (myKapFile, myNewKapFile)
os.remove(myKapFile)
except OSError:
pass
try:
os.rename (myTextFile, myNewTextFile)
os.remove(myTextFile)
except OSError:
pass
Reason for ChartBundler
- Lets talk a bit about amounts here and not low stress or high stress. Using the charts offline on a mobile device. Lets say the display is about 1024x1024 Pixel, then we will need at least 16 tiles per map. If we start on zoom level 8 with the bounding box and continue to zoom level 16 for the harbours, we need around 2 Mio tiles. This 16 tiles on zoom level 8 is about the northern Adria. If we want the Channel just skipping Lands End up to the belgian coast, this would be 6 by 5 on zoom level 8. --Alexej
- Hi Alexej, do not understand this paragraph!? 2 test datasets of mine:
- --Kannix (Diskussion) 16:22, 29. Jan. 2015 (UTC)