0

我正在尝试supervisor通过 xmlrpc 与之交谈。基于supervisorctl（尤其是这一行），我有以下内容，它似乎应该可以工作，而且确实可以工作，只要它连接到足以从服务器接收错误：

#socketpath is the full path to the socket, which exists
# None and None are the default username and password in the supervisorctl options
In [12]: proxy = xmlrpclib.ServerProxy('http://127.0.0.1', transport=supervisor.xmlrpc.SupervisorTransport(None, None, serverurl='unix://'+socketpath))

In [13]: proxy.supervisor.getState()

导致此错误：

---------------------------------------------------------------------------
ProtocolError                             Traceback (most recent call last)
/home/marcintustin/webapps/django/oneclickcosvirt/oneclickcos/<ipython-input-13-646258924bc2> in <module>()
----> 1 proxy.supervisor.getState()

/usr/local/lib/python2.7/xmlrpclib.pyc in __call__(self, *args)
   1222         return _Method(self.__send, "%s.%s" % (self.__name, name))
   1223     def __call__(self, *args):
-> 1224         return self.__send(self.__name, args)
   1225
   1226 ##


/usr/local/lib/python2.7/xmlrpclib.pyc in __request(self, methodname, params)
   1576             self.__handler,
   1577             request,
-> 1578             verbose=self.__verbose
   1579             )
   1580

/home/marcintustin/webapps/django/oneclickcosvirt/lib/python2.7/site-packages/supervisor/xmlrpc.pyc in request(self, host, handler, request_body, verbose)
    469                                           r.status,
    470                                           r.reason,
--> 471                                           '' )
    472         data = r.read()
    473         p, u = self.getparser()

ProtocolError: <ProtocolError for 127.0.0.1/RPC2: 401 Unauthorized>

这是unix_http_server部分supervisord.conf：

[unix_http_server]
file=/home/marcintustin/webapps/django/oneclickcosvirt/tmp/supervisor.sock   ; (the path to the socket file)
;chmod=0700                 ; socket file mode (default 0700)
;chown=nobody:nogroup       ; socket file uid:gid owner
;username=user              ; (default is no username (open server))
;password=123               ; (default is no password (open server))

因此，应该没有身份验证问题。

似乎我的代码在所有材料方面都与 中的等效代码相同supervisorctl，但supervisorctl实际上有效。我究竟做错了什么？

4

2 回答 2

7

您的代码看起来基本正确。我正在使用 Python 2.7 运行 Supervisor 3.0，并给出以下信息：

import supervisor.xmlrpc
import xmlrpclib

p = xmlrpclib.ServerProxy('http://127.0.0.1',
        transport=supervisor.xmlrpc.SupervisorTransport(
            None, None,
            'unix:///home/lars/lib/supervisor/tmp/supervisor.sock'))

print p.supervisor.getState()

我得到：

{'statename': 'RUNNING', 'statecode': 1}

您确定您正在运行的 Supervisor 实例正在使用您认为的配置文件吗？如果你supervisord在调试模式下运行，你看到连接了吗？

于 2012-07-31T16:19:28.220 回答
1

我不使用 xmlrpclib 中的 ServerProxy，而是使用 Server 类，并且不必定义任何到套接字的传输或路径。不确定您的目的是否需要，但这是我经常使用的瘦客户端。它几乎直接来自文档。

python -c "import xmlrpclib;\
supervisor_client = xmlrpclib.Server('http://localhost:9001/RPC2');\
print( supervisor_client.supervisor.stopProcess(<some_proc_name>) )"
于 2015-08-07T16:15:20.507 回答