1

我正在制作客户端服务器示例的变体，它只使用 Redstone 框架返回 JSON 字符串。它有3条路线：

  • / => 获取整个列表或名称
  • /add/name => 将“名称”添加到列表并获取列表
  • /remove/name=> 从列表中删除“名称”并获取列表

当我在本地进行测试时，一切正常，但是，当我部署到 App Engine 时，尝试将元素添加到 gcloud db 时出现错误。错误是

例外：尝试插入 1 个实体，但响应似乎表明我们插入了 0 个实体。包：appengine/src/api_impl/raw_datastore_v3_impl.dart 416:11 DatastoreV3RpcImpl.commit。飞镖：隔离_RawReceivePortImpl._handleMessage

您可以在此 URL http://web3.arista-dev.appspot.com/add/my-name上实时测试错误

删除似乎也不起作用，但不会产生错误。这是我的代码：

import 'dart:io';
import 'dart:async';

import 'package:shelf/shelf.dart' as shelf;
import 'package:redstone/server.dart' as app;

import 'package:restonetest/model.dart';

import 'package:gcloud/db.dart';
import 'package:appengine/appengine.dart';

Key get itemsRoot => context.services.db.emptyKey.append (ItemRoot, id: 1);

DatastoreDB db = context.services.db;

Future<List<Item>> queryItems ()
{
    var query = context.services.db.query (Item, ancestorKey: itemsRoot)
        ..order ('name');

    return query.run ().toList ();
}

Future<List<Item>> addItemToDB (Item item)
{
    return db.query(Item, ancestorKey: itemsRoot).run()

        .any((i) => i.name == item.name)

        .then((exists) 
        {
                return ! exists ? db.commit(inserts: [item]) : false;
        });
}

@app.Route("/")
helloWorld() => queryItems();

@app.Route('/add/:name')
addItem (String name)
{
    return addItemToDB (new Item.create (name, itemsRoot)).then ((_) 
    {
        print (name);    
        return helloWorld();
    });
}

@app.Route('/delete/:name')
deleteItem (String name) 
{
    var query = db.query (Item, ancestorKey: itemsRoot)..filter('name =', name);

    return query.run().toList().then((list) 
    { 
        var toDelete = list.map((i) => i.key).toList();
        return db.commit(deletes: toDelete);
    })

    .then((_) => helloWorld());
}

main() {
    app.setupConsoleLog();
    app.setUp();
    runAppEngine(app.handleRequest);
    //app.start();
}
4

1 回答 1

2

目前， package:appengine 只允许在请求处理程序中调用 API 服务：

每个请求处理程序调用都会获得一组新的服务。这允许 package:appengine 给每个请求处理程序，例如不同的日志服务实例。这允许按请求对所有日志记录 API 调用进行分组。

在 dart / package:appengine 中实现这一点的方法是使用Zones。对于每个传入的请求，package:appengine 使用 API 服务创建一个新区域，并在其中调用请求处理程序。然后处理程序可以使用“context.services”。进行 API 调用。

所以上面发布的程序中的问题是，DatastoreDB 服务从第一个请求中被缓存（全局字段被延迟初始化）并且可能不再适用于后续请求。

改变

DatastoreDB db = context.services.db;

至

DatastoreDB get db => context.services.db;

应该可以解决这个问题，因为每次都会从请求处理程序区域重新获取服务对象。

话虽如此：

a) 被吞下的错误报告具有误导性，将在 package:appengine 中修复

b) 在不久的将来，我们将允许后台任务/任务在请求处理程序之外进行 API 调用。目前缺少此功能，但将实施。

我希望这有帮助。

于 2014-11-26T13:08:34.393 回答