使用Python 将shapefile导入mongodb

使用Python 将shapefile导入mongodb

随着big data时代的到来，各个行业都在考虑能不能把big data的思路、方法引入进来，GIS行业也不能免俗。

下面就介绍一下如何将shapefile导入mongodb中

1首先安装pyshp 和pymongo 库

2 安装mongodb，并正确运行

3 执行下面的python脚本

import pymongo

from pymongo.connection import Connection

def readSHPPoint(append):

    fileP = u'E:\data\supermarket_webMercator\supermarket.shp'

    sf = shapefile.Reader(fileP)

    shapeRecs = sf.shapeRecords()

    mongodb_server='192.168.120.100'

    mongodb_port = 27017

    mongodb_collection ='supermarket'

    mongodb_db = 'gisdb'

    connection = Connection(mongodb_server, mongodb_port)

    print 'Getting database %s' % mongodb_db

    db = connection[mongodb_db]

    print 'Getting the collection %s' % mongodb_collection

    collection = db[mongodb_collection]

    if append == False:

        print 'Removing features from the collection...'

        collection.remove({})

    print 'Starting loading features...'

       

    for shaperec in shapeRecs:

        mongofeat = {}

        #'{x='',y=''}'

        strX = "%.3f" % shaperec.shape.points[0][0]

        strY = "%.3f" % shaperec.shape.points[0][1]

        mongogeom = '{x="'+strX+'",y="'+strY+'"}'

        print mongogeom

        mongofeat['geom'] = mongogeom

        mongofeat['name'] = shaperec.record[1].decode('GB2312').encode('utf-8')

        collection.insert(mongofeat)

    #create 2d index

    collection.create_index([("geom", pymongo.GEO2D)])

if __name__ == "__main__":

  readSHPPoint(False)

目前mongodb只支持点类型的数据，并提供空间索引。

使用mongodb可以很方便的满足高并发的并且简单的需求，例如POI的周边查询API查询

 

本文转载自：http://www.giser.net/?p=1076