GAE Go 应用文本搜索指南：Datastore 限制与跨语言实现策略

service: search-service # 定义服务名称，Go 应用将通过此名称调用
runtime: python27
api_version: 1
threadsafe: true

handlers:
- url: /index
  script: main.app # 索引文档的入口
- url: /search
  script: main.app # 执行搜索的入口

# search_service/main.py
import webapp2
import json
from google.appengine.api import search # GAE 全文搜索 API

# 定义全文索引的名称
INDEX_NAME = 'my_go_app_full_text_index'

class IndexDocumentHandler(webapp2.RequestHandler):
    """处理文档索引请求的 HTTP Handler"""
    def post(self):
        try:
            # 从 Go 应用接收 JSON 格式的文档数据
            data = json.loads(self.request.body)
            doc_id = data.get('id')
            title = data.get('title')
            content = data.get('content')

            if not doc_id or not title or not content:
                self.response.set_status(400)
                self.response.write(json.dumps({'error': 'Missing required fields: id, title, content'}))
                return

            # 构建 GAE search.Document 对象
            fields = [
                search.TextField(name='title', value=title),
                search.TextField(name='content', value=content),
                # 可以根据需要添加其他字段，如数字、原子字段等
            ]
            doc = search.Document(doc_id=doc_id, fields=fields)

            # 获取索引并添加/更新文档
            index = search.Index(name=INDEX_NAME)
            index.put(doc) # put 方法会创建或更新文档

            self.response.set_status(200)
            self.response.write(json.dumps({'message': 'Document indexed successfully', 'doc_id': doc_id}))

        except Exception as e:
            self.response.set_status(500)
            self.response.write(json.dumps({'error': str(e)}))

class SearchHandler(webapp2.RequestHandler):
    """处理文本搜索请求的 HTTP Handler"""
    def get(self):
        query_string = self.request.get('q') # 从 Go 应用接收搜索关键词
        if not query_string:
            self.response.set_status(400)
            self.response.write(json.dumps({'error': 'Missing query parameter "q"'}))
            return

        try:
            # 构建搜索查询选项
            options = search.QueryOptions(
                limit=10, # 返回最多10个结果
                # cursor=search.Cursor(), # 用于分页
                # returned_fields=['title', 'content'], # 指定返回的字段
            )
            query = search.Query(query_string=query_string, options=options)

            # 执行搜索
            index = search.Index(name=INDEX_