coreseek為了擴展，增加了python數(shù)據(jù)源功能，從而得以無限擴展Coreseek/Sphinx的數(shù)據(jù)獲取功能。
這樣做的話，coreseek就非常靈活，基本上可以對所有的數(shù)據(jù)建立搜索引擎，只要有自己的python數(shù)據(jù)源基類。
這里配一下 Microsoft SQL Server 和 python基類的寫法：
csft_python.conf
python
{
path = /to/coreseek-3.2.14/testpack/etc/pysource
path = /to/coreseek-3.2.14/testpack/etc/pysource/csft_demo_pymssql #BSD、Linux環(huán)境下設(shè)置
}
source python_demo
{
type = python
name = csft_demo_pymssql.MainSource
#name = MainSource
}
index python_demo
{
source = python_demo #對應(yīng)的source名稱
path = var/data/python_demo
#docinfo = extern
mlock = 0
morphology = none
min_word_len = 1
html_strip = 0
#charset_dictpath = /usr/local/mmseg3/etc/ #BSD、Linux環(huán)境下設(shè)置，/符號結(jié)尾
#charset_dictpath = etc/ #Windows環(huán)境下設(shè)置，/符號結(jié)尾
charset_type = utf-8
}
indexer
{
mem_limit = 128M
}
searchd
{
listen = 9353
read_timeout = 5
max_children = 30
max_matches = 1000
seamless_rotate = 0
preopen_indexes = 0
unlink_old = 1
pid_file = var/log/searchd_python.pid
log = var/log/searchd_python.log
query_log = var/log/query_python.log
}
/to/coreseek-3.2.14/testpack/etc/pysource/csft_demo_pymssql
下的__init__.py
# -*- coding: UTF-8 -*-
from os import path
import os
import sys
import pymssql
import datetime
class MainSource(object):
def __init__(self, conf):
self.conf = conf
self.idx = 0
self.data = []
self.conn = None
self.cur = None
def GetScheme(self): #獲取結(jié)構(gòu)，docid、文本、整數(shù)
return [
('id' , {'docid':True, } ),
('xx', { 'type':'text'} ),
('xx1', {'type':'integer'} ),
]
def GetFieldOrder(self): #字段的優(yōu)先順序
return [('name')]
def Connected(self): #如果是數(shù)據(jù)庫，則在此處做數(shù)據(jù)庫連接
if self.conn==None:
self.conn = pymssql.connect(host='192.168.40.105', user='sa', password='987654321sa', database='xxx', as_dict=True,charset='cp936')
self.cur = self.conn.cursor()
sql = 'SELECT top 12 id,xx,xx1 FROM tbxx'
self.cur.execute(sql)
self.data = [ row for row in self.cur]
pass
def NextDocument(self): #取得每一個文檔記錄的調(diào)用
if self.idx < len(self.data):
try:
item = self.data[self.idx]
self.docid = self.id = item[0] #'docid':True
self.xx = item[1].encode('utf-8')
self.xx1 = 1
self.idx += 1
return True
except:
return False
else:
return False
if __name__ == "__main__": #直接訪問演示部分
conf = {}
source = MainSource(conf)
source.Connected()
while source.NextDocument():
print "id=%d, subject=%s" % (source.docid, source.xx)
pass
#eof
參考地址：http://www.coreseek.cn/products-install/python/
posted on 2013-03-14 17:38
漂漂 閱讀(1488)
評論(0) 編輯 收藏 引用