文件名称：python hbase读取数据发送kafka的方法
文件大小：39KB
文件格式：PDF
更新时间：2024-02-09 22:59:58
AS base hbase
本例子实现从hbase获取数据，并发送kafka。 使用 #!/usr/bin/env python #coding=utf-8 import sys import time import json sys.path.append('/usr/local/lib/python3.5/site-packages') from thrift import Thrift from thrift.transport import TSocket from thrift.transport import TTransport from thrift.protocol import TBinaryPro