Odoo 中文社区

    • 注册
    • 登录
    • 搜索
    • 版块
    • 标签
    • 热门
    • 用户
    • 群组

    Odoo中文社区可以通过以下两个域名访问:shine-it.net , odoo.net.cn

    由于系统升迁的原因,本论坛部分较早期的内容存在格式和链接损坏失效的问题,并非本论坛系统本身的缺陷,望谅解

    本社区没有维护任何QQ群讨论组,任何与本社区同名的QQ群讨论组的言论与本社区无关!

    开发人员可以登录gitter讨论组: http://gitter.im/odoo-china/Talk, 需要github账号

    如果您登录系统碰到问题,请在微信公众号留言:

    Openerp xml_rpc数据操作过快导致CannotSendRequest的解决方法

    Odoo 开发与实施交流
    1
    2
    3636
    正在加载更多帖子
    • 从旧到新
    • 从新到旧
    • 最多赞同
    回复
    • 在新帖中回复
    登录后回复
    此主题已被删除。只有拥有主题管理权限的用户可以查看。
    • D
      daishaofei 最后由 编辑

      xml_rpc操作数据库,写入过快就会报连接错误
      类似这样:

      <br />&nbsp; &nbsp; sock.execute(dbname, uid, pwd, &#039;stock.seeed.delivery&#039;, &#039;write&#039;, id, values)<br />&nbsp; File &quot;/usr/lib/python2.7/xmlrpclib.py&quot;, line 1224, in __call__<br />&nbsp; &nbsp; return self.__send(self.__name, args)<br />&nbsp; File &quot;/usr/lib/python2.7/xmlrpclib.py&quot;, line 1578, in __request<br />&nbsp; &nbsp; verbose=self.__verbose<br />&nbsp; File &quot;/usr/lib/python2.7/xmlrpclib.py&quot;, line 1264, in request<br />&nbsp; &nbsp; return self.single_request(host, handler, request_body, verbose)<br />&nbsp; File &quot;/usr/lib/python2.7/xmlrpclib.py&quot;, line 1289, in single_request<br />&nbsp; &nbsp; self.send_request(h, handler, request_body)<br />&nbsp; File &quot;/usr/lib/python2.7/xmlrpclib.py&quot;, line 1391, in send_request<br />&nbsp; &nbsp; connection.putrequest(&quot;POST&quot;, handler, skip_accept_encoding=True)<br />&nbsp; File &quot;/usr/lib/python2.7/httplib.py&quot;, line 856, in putrequest<br />&nbsp; &nbsp; raise CannotSendRequest()<br />CannotSendRequest<br />
      


      解决这个问题就是每次数据操作前登录,操作后退出,
      让我想到了装饰器,直接上代码

      <br />#encoding=utf-8<br />import xmlrpclib<br /><br />username = &#039;admin&#039; #the user<br />pwd = &#039;test&#039;&nbsp; &nbsp; &nbsp; #the password of the user<br />dbname = &#039;test&#039;&nbsp; &nbsp; #the database<br />host = &#039;http://192.168.1.116:8069&#039;<br /><br />def log_in_out(*logs,**kwlogs):<br />&nbsp; &nbsp; def deco(func):<br />&nbsp; &nbsp; &nbsp; &nbsp; def wrapper(*args,**kwargs):<br />&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; dbname,username,pwd,host = kwlogs&#91;&#039;dbname&#039;],kwlogs&#91;&#039;username&#039;],kwlogs&#91;&#039;pwd&#039;],kwlogs&#91;&#039;host&#039;]<br />&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sock_common = xmlrpclib.ServerProxy (&#039;%s/xmlrpc/common&#039;%host)<br />&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; uid = sock_common.login(dbname, username, pwd)<br />&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sock = xmlrpclib.ServerProxy(&#039;%s/xmlrpc/object&#039;%host)<br />&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; kwargs&#91;&#039;sock&#039;] = sock<br />&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; kwargs&#91;&#039;uid&#039;] = uid<br />&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; data = func(*args,**kwargs)<br />&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sock_common.logout(dbname, username, pwd)<br />&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return data<br />&nbsp; &nbsp; &nbsp; &nbsp; return wrapper<br />&nbsp; &nbsp; return deco<br /><br />##get_list<br />@log_in_out(dbname=dbname,username=username,pwd=pwd,host=host)<br />def get_list(limit=20000, date_start=None, date_end=None, sock=None, uid=None):<br />&nbsp; &nbsp; &#039;&#039;&#039;get the list of track&#039;&#039;&#039;<br />&nbsp; &nbsp; args = [(&#039;state&#039;,&#039;in&#039;, (&#039;traceable&#039;,&#039;partdone&#039;,&#039;done&#039;)), (&#039;transfer_way&#039;, &#039;not like&#039;, &#039;%自取%&#039;),<br />&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; (&#039;transfer_way&#039;, &#039;not in&#039;, (&#039;&#039;,)),&#039;|&#039;,(&#039;track_state&#039;,&#039;not like&#039;,&#039;%成功签收%&#039;),(&#039;track_state&#039;,&#039;=&#039;,False)]<br />&nbsp; &nbsp; if date_start:<br />&nbsp; &nbsp; &nbsp; &nbsp; args.insert(0, (&#039;traceable_time&#039;, &#039;&gt;=&#039;, date_start),)<br />&nbsp; &nbsp; if date_end:<br />&nbsp; &nbsp; &nbsp; &nbsp; args.insert(0, (&#039;traceable_time&#039;, &#039;&lt;=&#039;, date_end),)<br />&nbsp; &nbsp; ids = sock.execute(dbname, uid, pwd, &#039;stock.delivery&#039;, &#039;search&#039;, args)<br />&nbsp; &nbsp; ids = sorted(ids,reverse=True)[:limit]<br />&nbsp; &nbsp; print len(ids)<br />&nbsp; &nbsp; fields = &#91;&#039;id&#039;,&#039;logistic_sn&#039;,&#039;transfer_way&#039;,&#039;track_state&#039;,&#039;traceable_time&#039;,&#039;name&#039;] #fields to read<br />&nbsp; &nbsp; data = sock.execute(dbname, uid, pwd, &#039;stock.delivery&#039;, &#039;read&#039;, ids, fields) #ids is a list of id<br />&nbsp; &nbsp; return data<br /><br />@log_in_out(dbname=dbname,username=username,pwd=pwd,host=host)<br />def write_track(id,values,sock=None,uid=None):<br />&nbsp; &nbsp; sock.execute(dbname, uid, pwd, &#039;stock.delivery&#039;, &#039;write&#039;, id, values)<br />
      
      1 条回复 最后回复 回复 引用 0
      • First post
        Last post