+
+ def get_apikey(self, apikey):
+ try:
+ url = self.base_url + "/apiKeys/%s" % apikey
+ ret = requests.get(url)
+ logger.info('get apiKey, response status_code: %s, body: %s', ret.status_code, ret.json())
+ if ret.status_code != 200:
+ raise DmaapClientException(ret.json())
+ ret = ret.json()
+ return ret
+ except Exception as e:
+ raise DmaapClientException('get apikey from dmaap failed: ' + e.message)
+
+ def delete_apikey(self):
+ pass
+
+ def update_apikey(self, apikey, email, description):
+ pass