#!/usr/bin/python import json import urllib2 import base64 import zlib # Overall WS Access Variables dbsAlias = 'xTD150' wsHost = 'dragon.teradata.ws' wsPort = '1080' query_path = '/tdrest/systems/' + dbsAlias + '/queries' database_path = '/tdrest/systems/' + dbsAlias + '/databases' wsUser = 'hack_user02' wsPass = 'tdhackathon' def rest_request (query): url = 'http://' + wsHost + ':' + wsPort + query_path headers={} headers['Content-Type'] = 'application/json' headers['Accept'] = 'application/vnd.com.teradata.rest-v1.0+json' headers['Authorization'] = "Basic %s" % base64.encodestring('%s:%s' % (wsUser, wsPass)).replace('\n', ''); # Set query bands queryBands = {} queryBands['applicationName'] = 'MyApp' queryBands['version'] = '1.0' # Set request fields. including SQL data = {} data['query'] = query data['queryBands'] = queryBands data['format'] = 'array' # Build request. request = urllib2.Request(url, json.dumps(data), headers) #Submit request try: response = urllib2.urlopen(request); # Check if result have been compressed. if response.info().get('Content-Encoding') == 'gzip': response = zlib.decompress(response.read(), 16+zlib.MAX_WBITS) else: response = response.read(); except urllib2.HTTPError, e: print 'HTTPError = ' + str(e.code) response = e.read(); except urllib2.URLError: print 'URLError = ' + str(e.reason) response = e.read(); # Parse response to confirm value JSON. results = json.loads(response); #print json.dumps(results, indent=4, sort_keys=True) return results["results"][0]["data"] def perform_query(query): return rest_request(query) def get_columns(database, table): url = 'http://' + wsHost + ':' + wsPort + database_path + "/" + database + "/tables/" + table print(url) headers={} headers['Content-Type'] = 'application/json' headers['Accept'] = 'application/vnd.com.teradata.rest-v1.0+json' headers['Authorization'] = "Basic %s" % base64.encodestring('%s:%s' % (wsUser, wsPass)).replace('\n', ''); # Set query bands queryBands = {} queryBands['applicationName'] = 'MyApp' queryBands['version'] = '1.0' # Set request fields. including SQL data = {} data['queryBands'] = queryBands data['format'] = 'array' # Build request. request = urllib2.Request(url, headers=headers) #Submit request try: response = urllib2.urlopen(request); # Check if result have been compressed. if response.info().get('Content-Encoding') == 'gzip': response = zlib.decompress(response.read(), 16+zlib.MAX_WBITS) else: response = response.read(); except urllib2.HTTPError, e: print 'HTTPError = ' + str(e.code) response = e.read(); except urllib2.URLError: print 'URLError = ' + str(e.reason) response = e.read(); # Parse response to confirm value JSON. results = json.loads(response); #print json.dumps(results, indent=4, sort_keys=True) return results def get_data(database, table): columns = get_columns(database, table)["columns"] columns = [column["name"] for column in columns] data = perform_query ( 'select * from ' + database + "." + table) data = [dict(zip(columns, d)) for d in data] return data
Run
Reset
Share
Import
Link
Embed
Language▼
English
中文
Python Fiddle
Python Cloud IDE
Follow @python_fiddle
Browser Version Not Supported
Due to Python Fiddle's reliance on advanced JavaScript techniques, older browsers might have problems running it correctly. Please download the latest version of your favourite browser.
Chrome 10+
Firefox 4+
Safari 5+
IE 10+
Let me try anyway!
url:
Go
Python Snippet
Stackoverflow Question