...
|
...
|
@@ -77,7 +77,6 @@ class EMRClusterScanner(object): |
|
|
nodeList = result['data']['nodeList']
|
|
|
for node in nodeList:
|
|
|
emrNodeIps.append(node['ip'])
|
|
|
print node['ip']
|
|
|
nodesCnt += len(nodeList)
|
|
|
totalCnt = result['data']['totalCnt']
|
|
|
if nodesCnt < totalCnt:
|
...
|
...
|
@@ -110,7 +109,6 @@ class EMRClusterScanner(object): |
|
|
|
|
|
def getHostsInFile(self,data,prefix):
|
|
|
#读取当前的Inventory信息,截取emr-recom下的所有ip数据用于和最新采集的ip列表进行匹配
|
|
|
print 'prefix:',prefix
|
|
|
rexContent = re.compile(r'(\[{0}\][\d+\.\d+\.\d+\.\d+\s*]*)'.format(prefix),re.S)
|
|
|
rexIp = re.compile(r'(\d+\.\d+\.\d+\.\d+)')
|
|
|
content = rexContent.findall(data)
|
...
|
...
|
|