问题描述
我正在使用Grakn 1.8.1,python 3.6.8,grakn-client 1.8.1和grpcio 1.24.1。
我定义了一个简单的架构(schema.gql)来执行测试:
define
nome sub attribute,value string;
cpf_srfb sub attribute,value string;
id_srfb sub attribute,value string;
hops_de_contraparte sub attribute,value string;
pessoa_fisica sub entity,has nome,has cpf_srfb,has id_srfb,has hops_de_contraparte;
此方案已使用grakn控制台正确加载,并且键空间称为“ srfb”。
之后,我创建了一个仅包含一个实例的数据文件(data.sql):
insert $pf isa pessoa_fisica,has nome "GUSTAVO RIBEIRO SOARES PINTO",has cpf_srfb "***106887**",has id_srfb "***106887**GUSTAVO RIBEIRO SOARES PINTO",has hops_de_contraparte "5";
同样,使用grakn-console可以完美地进行数据加载。
当我通过控制台加载架构,然后尝试通过python api加载数据时,会发生问题。
我的python脚本就是:
from grakn.client import GraknClient
uri = "localhost:48555"
keyspace = 'srfb'
filepath = 'C:\grakn\grakn_181\data.gql'
with open(filepath,mode='r') as file:
insert_query = file.read()
with GraknClient(uri) as client:
with client.session(keyspace) as session:
with session.transaction().write() as transaction:
transaction.query(insert_query)
transaction.commit()
那时,发生了我无法纠正的错误:
Traceback (most recent call last):
File "C:\Users\jorge\AppData\Local\Programs\Python\Python36\lib\site-packages\grakn\service\Session\util\Communicator.py",line 166,in _block_for_next
response = next(self._response_iterator)
File "C:\Users\jorge\AppData\Local\Programs\Python\Python36\lib\site-packages\grpc\_channel.py",line 388,in __next__
return self._next()
File "C:\Users\jorge\AppData\Local\Programs\Python\Python36\lib\site-packages\grpc\_channel.py",line 382,in _next
raise self
grpc._channel._Rendezvous: <_Rendezvous of RPC that terminated with:
status = StatusCode.UNKNOWN
details = "grakn.core.kb.graql.exception.GraqlSemanticException: hops_de_contraparte doesn't have an 'isa',a 'sub' or an 'id'. Please check server logs for the stack trace."
debug_error_string = "{"created":"@1603911191.241000000","description":"Error received from peer ipv6:[::1]:48555","file":"src/core/lib/surface/call.cc","file_line":1055,"grpc_message":"grakn.core.kb.graql.exception.GraqlSemanticException: hops_de_contraparte doesn't have an 'isa',a 'sub' or an 'id'. Please check server logs for the stack trace.","grpc_status":2}"
>
During handling of the above exception,another exception occurred:
Traceback (most recent call last):
File "teste.py",line 17,in <module>
transaction.commit()
File "C:\Users\jorge\AppData\Local\Programs\Python\Python36\lib\site-packages\grakn\client.py",line 160,in commit
self._tx_service.commit()
File "C:\Users\jorge\AppData\Local\Programs\Python\Python36\lib\site-packages\grakn\service\Session\TransactionService.py",line 54,in commit
self._communicator.single_request(request)
File "C:\Users\jorge\AppData\Local\Programs\Python\Python36\lib\site-packages\grakn\service\Session\util\Communicator.py",line 192,in single_request
return SingleResolver(self,request).get()
File "C:\Users\jorge\AppData\Local\Programs\Python\Python36\lib\site-packages\grakn\service\Session\util\Communicator.py",line 70,in get
response = self._communicator._block_for_next(self)
File "C:\Users\jorge\AppData\Local\Programs\Python\Python36\lib\site-packages\grakn\service\Session\util\Communicator.py",line 184,in _block_for_next
raise self._error
grakn.exception.GraknError.GraknError: Server/network error: <_Rendezvous of RPC that terminated with:
status = StatusCode.UNKNOWN
details = "grakn.core.kb.graql.exception.GraqlSemanticException: hops_de_contraparte doesn't have an 'isa',"grpc_status":2}"
>
generated from request: iter_req {
options {
}
query_iter_req {
query: "insert $pf isa pessoa_fisica,has nome \"GUSTAVO RIBEIRO SOARES PINTO\",has cpf_srfb \"***106887**\",has id_srfb \"***106887**GUSTAVO RIBEIRO SOARES PINTO\",has hops_de_contraparte \"5\";"
options {
}
}
}
grakn日志显示以下记录:
2020-10-28 15:15:45,615 [grpc-request-handler-3] ERROR g.c.s.r.SessionService$TransactionListener - Runtime Exception in RPC TransactionListener:
java.util.concurrent.ExecutionException: grakn.core.kb.graql.exception.GraqlSemanticException: hops_de_contraparte doesn't have an 'isa',a 'sub' or an 'id'
at java.util.concurrent.FutureTask.report(Unknown Source)
at java.util.concurrent.FutureTask.get(Unknown Source)
at grakn.core.server.rpc.SessionService$TransactionListener.process(SessionService.java:319)
at grakn.core.server.rpc.SessionService$TransactionListener.onNext(SessionService.java:196)
at grakn.core.server.rpc.SessionService$TransactionListener.onNext(SessionService.java:156)
at io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onMessage(ServerCalls.java:251)
at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailableInternal(ServerCallImpl.java:309)
at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailable(ServerCallImpl.java:292)
at io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable.runInContext(ServerImpl.java:779)
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
Caused by: grakn.core.kb.graql.exception.GraqlSemanticException: hops_de_contraparte doesn't have an 'isa',a 'sub' or an 'id'
最初,我认为属性的声明存在问题,但事实并非如此,因为同一插入可以通过控制台完美地工作。
我该怎么做才能使用python API?有人知道我可能在做错什么吗?
解决方法
如果您不从文件中读取文件,而直接设置插入查询,是否可以正常工作?
insert_query ="insert $pf isa pessoa_fisica,has nome \"GUSTAVO RIBEIRO SOARES PINTO\",has cpf_srfb \"***106887**\",has id_srfb \"***106887**GUSTAVO RIBEIRO SOARES PINTO\",has hops_de_contraparte \"5\";"
,
从已经通过控制台正确加载所有内容的事实中已经知道,您没有做任何明显的错误!
此消息:
hops_de_contraparte doesn't have an 'isa',a 'sub' or an 'id'
可以肯定地表明您从python客户端访问的键空间没有定义为hops_de_contraparte
的类型。您从控制台访问的键空间可能与从客户端访问的键空间不同。因此,请仔细检查以确保在使用控制台加载架构时,您正在使用-k
参数来提供键空间,例如:.\grakn console -k srfb -f 'C:\grakn\grakn_181\schema.gql
,以便它与用于客户端的键空间匹配。 / p>
如果失败,请尝试更改您要删除的hops_de_contraparte
查询,以查看是否是未定义的特定类型。按照Banjo的建议进行操作,然后尝试首先从Python字符串传递查询。
我清理了键空间,重新启动了所有过程,脚本正常运行。我不知道问题是什么,但问题已解决。感谢James和Banjo的帮助。