HBASE-25508 Add an example of using the thrift proxy in thrift-over-http mode
Closes #2888
Signed-off-by: stack <stack@apache.org>
diff --git a/hbase-examples/src/main/python/thrift1/demo_hbase_thrift_over_http_tls.py b/hbase-examples/src/main/python/thrift1/demo_hbase_thrift_over_http_tls.py
new file mode 100755
index 0000000..e2a4867
--- /dev/null
+++ b/hbase-examples/src/main/python/thrift1/demo_hbase_thrift_over_http_tls.py
@@ -0,0 +1,71 @@
+#!/usr/bin/env python
+'''
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+'''
+#
+# test thrift server over HTTP with SSL in place
+#
+# presumes thrift python lib is installed
+# presumes you have access to hbase thrift binding (i.e. you add gen-py to PYTHONPATH)
+# presumes thrift proxy is running on port 9090
+# presumes thrift proxy is running over https
+# presumes access to create and use tables in a namespace 'test'
+#
+# usage:
+# ./demo_hbase_thrift_over_http_tls.py host-running-thrift1.example.com
+import sys
+
+from thrift import Thrift
+from thrift.transport import THttpClient
+from thrift.protocol import TBinaryProtocol
+from hbase import Hbase
+from hbase.ttypes import ColumnDescriptor
+from hbase.ttypes import Mutation
+from hbase.ttypes import IOError as HBaseIOError
+
+print "[INFO] setup connection"
+transport = THttpClient.THttpClient("https://{0}:{1}".format(sys.argv[1], 9090))
+client = Hbase.Client(TBinaryProtocol.TBinaryProtocol(transport))
+
+table='test:thrift_proxy_demo'
+
+print "[INFO] start client"
+transport.open()
+
+print "[INFO] list the current tables"
+print client.getTableNames()
+
+print "[INFO] create a table, place some data"
+client.createTable(table, [ColumnDescriptor(name ='family1:')])
+client.mutateRow(table, 'row1', [Mutation(column = 'family1:cq1', value = 'foo'), Mutation(column = 'family1:cq2', value = 'foo')], {})
+client.mutateRow(table, 'row2', [Mutation(column = 'family1:cq1', value = 'bar'), Mutation(column = 'family1:cq2', value = 'bar')], {})
+client.mutateRow(table, 'row3', [Mutation(column = 'family1:cq1', value = 'foo'), Mutation(column = 'family1:cq2', value = 'foo')], {})
+client.mutateRow(table, 'row4', [Mutation(column = 'family1:cq1', value = 'bar'), Mutation(column = 'family1:cq2', value = 'bar')], {})
+
+
+print "[INFO] scan"
+scan_id = client.scannerOpen(table, 'row1', [], {})
+for row in client.scannerGetList(scan_id, 25):
+ print row
+client.scannerClose(scan_id)
+print "[INFO] get"
+for row in client.getRow(table, 'row3', {}):
+ print row
+
+print "[INFO] clean up"
+client.disableTable(table)
+client.deleteTable(table)
