Python NeoModel 如何 return 查询结果作为 JSON 对象

Python NeoModel how to return query result as JSON Object

我是 Python 的新手,在我的应用程序中,我使用 Neomodel 从 Neo4j 数据库加载和检索图形数据。

在我的一条路线中,我有以下功能:

@api_mod.route('/users')                                                            
def get_users():                                                                                                                                                        
     users = User.nodes #Returns a NodeSet                                                                                                                              
     list_of_users = list(users) #Converts the NodeSet object to a list                                                                                                                                                                                                                                                                    
     return json.dumps(dict(users = [user for user in list_of_users]))    

我的用户 class 定义如下:

class User(StructuredNode):
    user_id = StringProperty(unique_index=True, required=True)
    logged_in = RelationshipTo('Environment', 'LOGGED_IN', model=LoginAction)
    launched = RelationshipTo('Application', 'LAUNCHED', model=LaunchedAction)
    entered = RelationshipTo('Application', 'ENTERED', model=EnteredAction)
    accessed = RelationshipTo('Application', 'ACCESSED', model=AccessedAction)
    exited = RelationshipTo('Application', 'EXITED', model=ExitedAction)
    logged_out = RelationshipTo('Environment', 'LOGGED_OUT', model=LogoutAction)
    timed_out = RelationshipTo('Environment', 'TIME_OUT', model=TimeoutAction)

    def toJSON(self):
        return dict(user_id = self.user_id)

我的期望是我的 /users 路由将 return 一个包含数据库中所有用户的 JSON 对象。我知道 NodeSet 对象不能序列化为 JSON 对象,因此我尝试将其转换为列表。但是现在当我 运行 我得到以下错误: "TypeError: Object of type 'User' is not JSON serializable"

这是整个堆栈跟踪: 追溯(最近一次通话): 文件“/Users/mdebarros/.virtualenvs/useractivitylogs/lib/python3.6/site-packages/flask/app.py”,第 1997 行,在 call 中 return self.wsgi_app(环境,start_response) 文件“/Users/mdebarros/.virtualenvs/useractivitylogs/lib/python3.6/site-packages/flask/app.py”,第 1985 行,在 wsgi_app 响应 = self.handle_exception(e) 文件“/Users/mdebarros/.virtualenvs/useractivitylogs/lib/python3.6/site-packages/flask/app.py”,第 1540 行,在 handle_exception 中 再加注(exc_type,exc_value,待定) 文件“/Users/mdebarros/.virtualenvs/useractivitylogs/lib/python3.6/site-packages/flask/_compat.py”,第 33 行,重新加注 提升价值 文件“/Users/mdebarros/.virtualenvs/useractivitylogs/lib/python3.6/site-packages/flask/app.py”,第 1982 行,在 wsgi_app 响应 = self.full_dispatch_request() 文件“/Users/mdebarros/.virtualenvs/useractivitylogs/lib/python3.6/site-packages/flask/app.py”,第 1614 行,在 full_dispatch_request 中 rv = self.handle_user_exception(e) 文件“/Users/mdebarros/.virtualenvs/useractivitylogs/lib/python3.6/site-packages/flask/app.py”,第 1517 行,在 handle_user_exception 中 再加注(exc_type,exc_value,待定) 文件“/Users/mdebarros/.virtualenvs/useractivitylogs/lib/python3.6/site-packages/flask/_compat.py”,第 33 行,重新加注 提升价值 文件“/Users/mdebarros/.virtualenvs/useractivitylogs/lib/python3.6/site-packages/flask/app.py”,第 1612 行,在 full_dispatch_request 中 rv = self.dispatch_request() 文件“/Users/mdebarros/.virtualenvs/useractivitylogs/lib/python3.6/site-packages/flask/app.py”,第 1598 行,在 dispatch_request 中 return self.view_functionsrule.endpoint 文件“/Users/mdebarros/PycharmProjects/useractivitylogs/app/api/routes.py”,第 16 行,在 get_users 中 return json.dumps(dict(users = [user for user in list_of_users])) 文件“/usr/local/Cellar/python3/3.6.2/Frameworks/Python.framework/Versions/3.6/lib/python3.6/json/init。 py”,第 231 行,在转储中 return _default_encoder.encode(对象) 文件“/usr/local/Cellar/python3/3.6.2/Frameworks/Python.framework/Versions/3.6/lib/python3.6/json/encoder.py”,第 199 行,编码 块 = self.iterencode(o, _one_shot=真) 文件“/usr/local/Cellar/python3/3.6.2/Frameworks/Python.framework/Versions/3.6/lib/python3.6/json/encoder.py”,第 257 行,在 iterencode 中 return_iterencode(o, 0) 文件“/usr/local/Cellar/python3/3.6.2/Frameworks/Python.framework/Versions/3.6/lib/python3.6/json/encoder.py”,第 180 行,默认 o.class.姓名) 类型错误:'User' 类型的对象不是 JSON 可序列化的

关于如何处理此问题和 return 合适的 JSON 对象的任何帮助或建议?

提前感谢您的帮助。

--MD

如你所知,有必要的是用户class模型有一个方法来执行数据结构的翻译过程(序列化),要解决,一个解决方案是添加一个方法,做这个:

class User(StructuredNode):
    user_id = StringProperty(unique_index=True, required=True)
    logged_in = RelationshipTo('Environment', 'LOGGED_IN', model=LoginAction)
    launched = RelationshipTo('Application', 'LAUNCHED', model=LaunchedAction)
    entered = RelationshipTo('Application', 'ENTERED', model=EnteredAction)
    accessed = RelationshipTo('Application', 'ACCESSED', model=AccessedAction)
    exited = RelationshipTo('Application', 'EXITED', model=ExitedAction)
    logged_out = RelationshipTo('Environment', 'LOGGED_OUT', model=LogoutAction)
    timed_out = RelationshipTo('Environment', 'TIME_OUT', model=TimeoutAction)

@property
def serialize(self):
    return {
        'user_id': self.user_id,
        'logged_in': self.logged_in,
        'launched': self.launched,
        'entered': self.entered,
        'accessed': self.accessed,
        'exited': self.exited,
        'logged_out': self.logged_out,
        'timed_out'  : self.timed_out
   }

现在,由于添加了方法 属性 可以作为属性调用:

@api_mod.route('/users')                                                            
def get_users():                                                                                                                                                        
    users = User.nodes                                                                                                                            
    list_of_users = list(users)
    return json.dumps(dict(json_users = [user.serialize for user in list_of_users]))