Arcgis服务器将所有服务的属性写入CSV fi

2024-04-25 02:30:19 发布

您现在位置:Python中文网/ 问答频道 /正文

我有36个服务运行在ArcGIS服务器上,并希望导出csv文件中每个服务的所有属性。我设法在ESRI帮助台http://resources.arcgis.com/en/help/main/10.2/index.html#//0154000005wt000000的帮助下编写了一个代码,在请求中添加了属性“maxImageHeight”和“maxImageWidth”。但是,如果我运行代码,它开始工作,写入前22个服务的属性,但是之后它突然停止并返回

回溯(最近一次呼叫): 文件“D:\SCRIPTS\Py SCRIPTS\ArcPy\AGS-ArcPy\AGS_service_report_as_csv2.Py”,第436行,in 系统出口(主(系统argv[1:])) 文件“D:\SCRIPTS\Py SCRIPTS\ArcPy\AGS-ArcPy\AGS_service_report_as_csv2.Py”,第201行,在main中 +“不适用”+“\n” KeyError:'最大高度'

这很奇怪,因为它为第一批服务提供了“maxImageHeight”属性。在

代码:

# Reads the following properties from services and writes them to a comma-delimited file:
#  ServiceName, Folder, Type, Status, Min Instances, Max Instances, Max Wainting Time,Max Startup Time,Max Idle Time,Max Usage Time, KML,
#  WMS, WFS, WCS, Max Records, Cluster, Cache Directory, Jobs Directory, Output Directory

# For HTTP calls
import httplib, urllib, json

# For system tools
import sys

# For reading passwords without echoing
import getpass

def main(argv=None):

    # Ask for admin/publisher user name and password
    username = raw_input("Enter user name: ")
    password = getpass.getpass("Enter password: ")

    # Ask for server name & port
    serverName = raw_input("Enter server name: ")
    serverPort = 6080

    # Get the location and the name of the file to be created
    resultFile = raw_input("Output File (get the location and the name of the file to be created): ")

    # Get a token
    token = getToken(username, password, serverName, serverPort)

    # Get the root info
    serverURL = "/arcgis/admin/services/"
    #serverURL = "/arcgis/manager/services/"

    # This request only needs the token and the response formatting parameter
    params = urllib.urlencode({'token': token, 'f': 'json'})

    headers = {"Content-type": "application/x-www-form-urlencoded", "Accept": "text/plain"}

    # Connect to URL and post parameters
    httpConn = httplib.HTTPConnection(serverName, serverPort)
    httpConn.request("POST", serverURL, params, headers)

    # Read response
    response = httpConn.getresponse()
    if (response.status != 200):
        httpConn.close()
        print "Could not read folder information."
        return
    else:
        data = response.read()

        # Check that data returned is not an error object
        if not assertJsonSuccess(data):
            print "Error when reading server information. " + str(data)
            return
        else:
            print "Processed server information successfully. Now processing folders..."

        # Deserialize response into Python object
        dataObj = json.loads(data)
        httpConn.close()

        #Store the Folders in a list to loop on
        folders = dataObj["folders"]

        #Remove the System and Utilities folders
        folders.remove("System")
        #folders.remove("Utilities")

        #Add an entry for the root folder
        folders.append("")

        #Create the summary file of services
        serviceResultFile = open(resultFile,'w')
        #serviceResultFile.write("ServiceName,Folder,Type,Status,Min Instances,Max Instances,FeatureService,kml,wms,Max Records,Cluster,Cache Directory,Jobs Directory,Output Directory" + "\n")
        serviceResultFile.write("\
            ServiceName,\
            Folder,\
            Type,\
            MaxImageHeight,\
            MaxImageWidth,\
            Status,\
            Min Instances,\
            Max Instances,\
            Max Wainting Time,\
            Max Startup Time,\
            Max Idle Time,\
            Max Usage Time,\
            FeatureService,\
            kml,\
            wms,\
            wfs,\
            wcs,\
            Max Records,\
            Cluster,\
            Cache Directory,\
            Jobs Directory,\
            Output Directory" + "\n")

        #Loop on the found folders and discover the services and write the service information
        for folder in folders:

            # Determine if the loop is working on the root folder or not
            if folder != "":
                folder += "/"

            # Build the URL for the current folder
            folderURL = "/arcgis/admin/services/" + folder
            params = urllib.urlencode({'token': token, 'f': 'json'})
            headers = {"Content-type": "application/x-www-form-urlencoded", "Accept": "text/plain"}

            # Connect to URL and post parameters
            httpConn = httplib.HTTPConnection(serverName, serverPort)
            httpConn.request("POST", folderURL, params, headers)

            # Read response
            response = httpConn.getresponse()
            if (response.status != 200):
                httpConn.close()
                print "Could not read folder information."
                return
            else:
                data = response.read()

                # Check that data returned is not an error object
                if not assertJsonSuccess(data):
                    print "Error when reading folder information. " + str(data)
                else:
                    print "Processed folder information successfully. Now processing services..."

                # Deserialize response into Python object
                dataObj = json.loads(data)
                httpConn.close()

                # Loop through each service in the folder
                for item in dataObj['services']:

                    if item["type"] == "GeometryServer":# and folder == "":
                        # Build the Service URL
                        if folder:
                            sUrl = "/arcgis/admin/services/%s%s.%s" %(folder,item["serviceName"], item["type"])
                            statusUrl = "/arcgis/admin/services/%s%s.%s/status" %(folder,item["serviceName"], item["type"])
                        else:
                            sUrl = "/arcgis/admin/services/%s.%s" %(item["serviceName"], item["type"])
                            statusUrl = "/arcgis/admin/services/%s.%s/status" %(item["serviceName"], item["type"])



                        httpConn.request("POST", sUrl, params, headers)

                        # Get the response
                        servResponse = httpConn.getresponse()
                        readData = servResponse.read()
                        jsonOBJ = json.loads(readData)

                        # Build the Service URL to test the running status


                        # Submit the request to the server
                        httpConn.request("POST", statusUrl, params, headers)
                        servStatusResponse = httpConn.getresponse()

                        # Obtain the data from the response
                        readData = servStatusResponse.read()
                        jsonOBJStatus = json.loads(readData)

                        # Build the line to write to the output file

                        ln = str(jsonOBJ["serviceName"]) + ","\
                        + folder + ","\
                        + str(item["type"]) + ","\
                        + str(jsonOBJ["properties"]["maxImageHeight"]) + ","\
                        + str(jsonOBJ["properties"]["maxImageWidth"]) + ","\
                        + jsonOBJStatus['realTimeState'] + ","\
                        + str(jsonOBJ["minInstancesPerNode"]) + ","\
                        + str(jsonOBJ["maxInstancesPerNode"]) + ","\
                        + str(jsonOBJ["maxWaitTime"]) + ","\
                        + str(jsonOBJ["maxStartupTime"]) + ","\
                        + str(jsonOBJ["maxIdleTime"]) + ","\
                        + str(jsonOBJ["maxUsageTime"]) + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + str(jsonOBJ["clusterName"]) + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + "NA" + "\n"

                        # Write the results to the file
                        serviceResultFile.write(ln)

                        httpConn.close()

                    elif item["type"] == "SearchServer":# and folder == "":
                        if folder:
                            sUrl = "/arcgis/admin/services/%s%s.%s" %(folder,item["serviceName"], item["type"])
                            statusUrl = "/arcgis/admin/services/%s%s.%s/status" %(folder,item["serviceName"], item["type"])
                        else:
                            sUrl = "/arcgis/admin/services/%s.%s" %(item["serviceName"], item["type"])
                            statusUrl = "/arcgis/admin/services/%s.%s/status" %(item["serviceName"], item["type"])


                        httpConn.request("POST", sUrl, params, headers)

                        # Get the response
                        servResponse = httpConn.getresponse()
                        readData = servResponse.read()
                        jsonOBJ = json.loads(readData)


                        # Submit the request to the server
                        httpConn.request("POST", statusUrl, params, headers)

                        # Get the response
                        servStatusResponse = httpConn.getresponse()
                        readData = servStatusResponse.read()
                        jsonOBJStatus = json.loads(readData)

                        # Build the line to write to the output file

                        ln = str(jsonOBJ["serviceName"]) + ","\
                        + folder + ","\
                        + str(item["type"]) + ","\
                        + str(jsonOBJ["properties"]["maxImageHeight"]) + ","\
                        + str(jsonOBJ["properties"]["maxImageWidth"]) + ","\
                        + jsonOBJStatus['realTimeState'] + ","\
                        + str(jsonOBJ["minInstancesPerNode"]) + ","\
                        + str(jsonOBJ["maxInstancesPerNode"]) + ","\
                        + str(jsonOBJ["maxWaitTime"]) + ","\
                        + str(jsonOBJ["maxStartupTime"]) + ","\
                        + str(jsonOBJ["maxIdleTime"]) + ","\
                        + str(jsonOBJ["maxUsageTime"]) + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + str(jsonOBJ["clusterName"]) + ","\
                        + "NA" + ","\
                        + "NA" + ","\
                        + "NA" + "\n"

                        # Write the results to the file
                        serviceResultFile.write(ln)

                        httpConn.close()

#####MapServer########################################

                    elif item["type"] == "MapServer":

                        # Build the Service URL
                        if folder:
                            sUrl = "/arcgis/admin/services/%s%s.%s" %(folder,item["serviceName"], item["type"])
                        else:
                            sUrl = "/arcgis/admin/services/%s.%s" %(item["serviceName"], item["type"])

                        # Submit the request to the server
                        httpConn.request("POST", sUrl, params, headers)

                        # Get the response
                        servResponse = httpConn.getresponse()
                        readData = servResponse.read()
                        jsonOBJ = json.loads(readData)

                        # Build the Service URL to test the running status
                        if folder:
                            statusUrl = "/arcgis/admin/services/%s%s.%s/status" %(folder,item["serviceName"], item["type"])
                        else:
                            statusUrl = "/arcgis/admin/services/%s.%s/status" %(item["serviceName"], item["type"])

                        # Submit the request to the server
                        httpConn.request("POST", statusUrl, params, headers)

                        # Get the response
                        servStatusResponse = httpConn.getresponse()
                        readData = servStatusResponse.read()
                        jsonOBJStatus = json.loads(readData)

                        # Check for Map Cache
                        isCached = jsonOBJ["properties"]["isCached"]
                        if isCached == "true":
                            cacheDir = str(jsonOBJ["properties"]["cacheDir"])
                        else:
                            cacheDir = jsonOBJ["properties"]["isCached"]

                        if len(jsonOBJ["extensions"]) == 0:
                            # Build the line to write to the output file
                            ln = str(jsonOBJ["serviceName"]) + ","\
                            + folder + ","\
                            + str(item["type"]) + ","\
                            + str(jsonOBJ["properties"]["maxImageHeight"]) + ","\
                            + str(jsonOBJ["properties"]["maxImageWidth"]) + ","\
                            + jsonOBJStatus['realTimeState'] + ","\
                            + str(jsonOBJ["minInstancesPerNode"]) + ","\
                            + str(jsonOBJ["maxInstancesPerNode"]) + ","\
                            + "FeatServHolder" + ","\
                            + "Disabled" + ","\
                            + "Disabled" +","\
                            + str(jsonOBJ["properties"]["maxRecordCount"]) + ","\
                            + str(jsonOBJ["clusterName"]) + ","\
                            + cacheDir + ","\
                            + "NA" + ","\
                            + str(jsonOBJ["properties"]["outputDir"]) + "\n"
                        else:
                            # Extract the KML properties from the response
                            kmlProps = [mapKML for mapKML in jsonOBJ["extensions"] if mapKML["typeName"] == 'KmlServer']#.items()[0][1] == 'KmlServer']

                            # Extract the WMS properties from the response
                            wmsProps = [mapWMS for mapWMS in jsonOBJ["extensions"] if mapWMS["typeName"] == 'WMSServer']#.items()[0][1] == 'WMSServer']

                              Extract the WFS properties from the response
                            wfsProps = [mapWFS for mapWFS in jsonOBJ["extensions"] if mapWFS["typeName"] == 'WFSServer']#.items()[0][1] == 'WFSServer']

                             Extract the WCS properties from the response
                            wcsProps = [mapWCS for mapWCS in jsonOBJ["extensions"] if mapWCS["typeName"] == 'WCSServer']#.items()[0][1] == 'WCSServer']

                            # Extract the FeatureService properties from the response
                            featServProps = [featServ for featServ in jsonOBJ["extensions"] if featServ["typeName"] == 'FeatureServer']#.items()[0][1] == 'FeatureServer']

                            if len(featServProps) > 0:
                                featureStatus = str(featServProps[0]["enabled"])
                            else:
                                featureStatus = "NA"

                            if len(kmlProps) > 0:
                                kmlStatus = str(kmlProps[0]["enabled"])
                            else:
                                kmlStatus = "NA"

                            if len(wmsProps) > 0:
                                wmsStatus = str(wmsProps[0]["enabled"])
                            else:
                                wmsStatus = "NA"
#MZ#
                            if len(wfsProps) > 0:
                                wfsStatus = str(wfsProps[0]["enabled"])
                            else:
                                wfsStatus = "NA"
#MZ#
                            if len(wcsProps) > 0:
                                wcsStatus = str(wcsProps[0]["enabled"])
                            else:
                                wcsStatus = "NA"

                         ln = str(jsonOBJ["serviceName"]) + ","\
                            + folder + ","\
                            + str(item["type"]) + ","\
                            + str(jsonOBJ["properties"]["maxImageHeight"]) + ","\
                            + str(jsonOBJ["properties"]["maxImageWidth"]) + ","\
                            + jsonOBJStatus['realTimeState'] + ","\
                            + str(jsonOBJ["minInstancesPerNode"]) + ","\
                            + str(jsonOBJ["maxInstancesPerNode"]) + ","\
                            + str(jsonOBJ["maxWaitTime"]) + ","\
                            + str(jsonOBJ["maxStartupTime"]) + ","\
                            + str(jsonOBJ["maxIdleTime"]) + ","\
                            + str(jsonOBJ["maxUsageTime"]) + ","\
                            + featureStatus + ","\
                            + kmlStatus + ","\
                            + wmsStatus + ","\
                            + wfsStatus + ","\
                            + wcsStatus + ","\
                            + str(jsonOBJ["properties"]["maxRecordCount"]) + ","\
                            + str(jsonOBJ["clusterName"]) + ","\
                            + cacheDir + "," + "NA" + ","\
                            + str(jsonOBJ["properties"]["outputDir"]) + "\n"

                        # Write the results to the file
                        serviceResultFile.write(ln)

                    else:
                        # Close the connection to the current service
                        httpConn.close()

        # Close the file
        serviceResultFile.close()

def getToken(username, password, serverName, serverPort):
    # Token URL is typically http://server[:port]/arcgis/admin/generateToken
    tokenURL = "/arcgis/admin/generateToken"

    params = urllib.urlencode({'username': username, 'password': password, 'client': 'requestip', 'f': 'json'})

    headers = {"Content-type": "application/x-www-form-urlencoded", "Accept": "text/plain"}

    # Connect to URL and post parameters
    httpConn = httplib.HTTPConnection(serverName, serverPort)
    httpConn.request("POST", tokenURL, params, headers)

    # Read response
    response = httpConn.getresponse()
    if (response.status != 200):
        httpConn.close()
        print "Error while fetching tokens from admin URL. Please check the URL and try again."
        return
    else:
        data = response.read()
        httpConn.close()

        # Check that data returned is not an error object
        if not assertJsonSuccess(data):
            return

        # Extract the token from it
        token = json.loads(data)
        return token['token']


# A function that checks that the input JSON object
#  is not an error object.
def assertJsonSuccess(data):
    obj = json.loads(data)
    if 'status' in obj and obj['status'] == "error":
        print "Error: JSON object returns an error. " + str(obj)
        return False
    else:
        return True

if __name__ == "__main__":
    sys.exit(main(sys.argv[1:]))`

Tags: thetoifadminresponsetypeserviceproperties
1条回答
网友
1楼 · 发布于 2024-04-25 02:30:19

我通过添加bufsize成功地克服了这个错误

#Create the summary file of services
bufsize = 0
serviceResultFile = open(resultFile,'w',bufsize)

现在它在抱怨如何处理文件的结尾。还在做这个

^{pr2}$

相关问题 更多 >