cadastra_recurso_servidores.py 文件源码

def register(self):
        u"Register resource into CKAN"
        import ckanapi
        ckansite = ckanapi.RemoteCKAN(self.ckan_url, apikey=self.apikey)

        # resource url responds?
        resource = requests.head(self.url)
        self.size = int(resource.headers["content-length"])

        # resource exists?
        resources = ckansite.action.resource_search(query=u"url:%s" % self.url)
        if resources[u"count"] == 0:
            ckansite.action.resource_create(
                package_id = self.package_id,
                url = self.url,
                name = self.name,
                description = self.description,
                format = self.format,
                mimetype = self.mimetype,
                size = self.size,
            )