0
私はファブリックを実行scrapydタスクを使用して、サーバーは、実行されているタスクのIDを返しますが、私はr.statusを使用すると、エラーが発生します:'_AttributeString' オブジェクトは、どのように私はすべてのIDを取得するか、何の属性のステータス "エラーを持っていないコードの打撃を:?このデータをファブリックでどのように解析すればよいですか?
@task
def stop_slave_machine(slave_ip = None):
jobs_id = []
with cd("/spider/distributed/wzws"):
if not None:
r = local("curl http://%s:%s/listjobs.json?project=WzwsSpider" % (slave_ip, scrapyd_port))
print(r.status)
とサーバーのリターンデータ:
{"status": "ok", "running": [{"start_time": "2016-03-28 18:21:21.951943", "id": "d10eae6cf4ce11e5a6646cae8b23c5da", "spider": "wzws"}, {"start_time": "2016-03-28 18:21:26.945244", "id": "d11a47f4f4ce11e5a6646cae8b23c5da", "spider": "wzws"}, {"start_time": "2016-03-28 18:21:31.941162", "id": "d12320ccf4ce11e5a6646cae8b23c5da", "spider": "wzws"}, {"start_time": "2016-03-28 18:21:36.941122", "id": "d12975b2f4ce11e5a6646cae8b23c5da", "spider": "wzws"}, {"start_time": "2016-03-28 18:21:41.941010", "id": "d131096cf4ce11e5a6646cae8b23c5da", "spider": "wzws"}], "finished": [], "pending": [], "node_name": "XXXXXXX"}
%(slave_ip、scrapyd_portに)、キャプチャ=真) – rowele
私は従いません。私は 'r'が私の提案に既に設定されていると仮定しました。私はあなたのコードを 'import'行と' loads'呼び出しの間に置くように編集して、もっと明確にすることができます。 – Morgan
ええ、私は知っています。どうも – rowele