我正在尝试使用 bulkuploader 将一些数据上传到我的 App Engine 数据存储区。对于我的一种实体类型,我有一个从另一个计算的属性,所以我真的很想对每个实体进行一些后处理,因为它被导入以进行此计算。我不断看到 post_import_function 转换标签的简短提及,但没有真正全面的文档或示例。
现在,我只是尝试做一个简单的测试来让我的 post_import_function 工作。
我的实体模型:
class TestEntity(db.Model):
location = db.GeoPtProperty()
cells = db.StringListProperty() # Computed from location
我的 bulkloader.yaml 文件的相关部分如下所示:
- kind: TestEntity
[... connector info ...]
property_map:
[... transform info for __key__ and location here ...]
post_import_function: post_transform.post_process_testentity
还有我的 post_process_testentity 函数:
def post_process_testentity(input_dict, entity_instance, bulkload_state):
entity_instance.cells = [u'Hello there!']
return entity_instance
当我使用所有这些东西进行数据上传时,我没有收到任何错误(我知道正在输入 post_process_testentity,因为我在其中添加了一些正确运行的打印语句)。关于上传的一切工作,除了我的后期处理功能完全没有效果。当我使用数据查看器时,我的数据存储中没有“Hello there!”。
有人可以帮帮我吗?谢谢!