/usr/lib/python2.7/dist-packages/txwinrm/collect.py is in python-txwinrm 1.1.28-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 | ##############################################################################
#
# Copyright (C) Zenoss, Inc. 2013, all rights reserved.
#
# This content is made available according to terms specified in the LICENSE
# file at the top-level directory of this package.
#
##############################################################################
import logging
from collections import namedtuple
from twisted.internet import defer
from .enumerate import create_winrm_client, DEFAULT_RESOURCE_URI
from .util import (
ConnectionInfo,
ForbiddenError,
RequestError,
UnauthorizedError,
)
EnumInfo = namedtuple('EnumInfo', ['wql', 'resource_uri'])
log = logging.getLogger('winrm')
def create_enum_info(wql, resource_uri=DEFAULT_RESOURCE_URI):
return EnumInfo(wql, resource_uri)
class WinrmCollectClient(object):
@defer.inlineCallbacks
def do_collect(self, conn_info, enum_infos):
"""
conn_info has the following attributes
hostname
auth_type: basic or kerberos
username
password
scheme: http (https coming soon)
port: int
"""
client = create_winrm_client(conn_info)
items = {}
for enum_info in enum_infos:
try:
items[enum_info] = yield client.enumerate(
enum_info.wql, enum_info.resource_uri)
except (UnauthorizedError, ForbiddenError):
# Fail the collection for general errors.
raise
except RequestError:
# Store empty results for other query-specific errors.
continue
defer.returnValue(items)
# ----- An example of useage...
if __name__ == '__main__':
from pprint import pprint
import logging
from twisted.internet import reactor
logging.basicConfig()
winrm = WinrmCollectClient()
@defer.inlineCallbacks
def do_example_collect():
connectiontype = 'Keep-Alive'
conn_info = ConnectionInfo(
"10.30.50.34", "kerberos", "rbooth@SOLUTIONS.LOC", "", "http", 5985, connectiontype, "/home/zenoss/rbooth.keytab", '')
wql1 = create_enum_info(
'Select Caption, DeviceID, Name From Win32_Processor')
wql2 = create_enum_info(
'select Name, Label, Capacity from Win32_Volume')
items = yield winrm.do_collect(conn_info, [wql1, wql2])
pprint(items)
reactor.stop()
reactor.callWhenRunning(do_example_collect)
reactor.run()
|