昨天我在hbase上读代码,传输大量数据。我还没有接触到代码,但不知何故,当我今天回到它不想打印出数据。我在服务器上做的唯一一件事就是设置一个rest框架来写入数据库。下面是部分代码的工作原理(因此它看起来好像得到了一个连接)-
import happybase
connection = happybase.Connection('<ip-address>', '9090')
table = connection.table('rawdataingestion')
然后,当它到达这一部分时,它就停止工作了。
n = 0
li = []
for key, data in table.scan(row_start=None):
data = json.loads(data['cf:rawmsg'])
li.append(data)
n += 1
if n == 1000:
break
就像我说的,服务器上唯一改变的是我设置了rest端口(8000)。这就是问题所在吗?我只需要从数据库中提取数据。
1条答案
按热度按时间dzjeubhm1#
如果我错了,请纠正我,但似乎rest和thrift不能同时在同一台服务器上工作。因此,我可以使用thrift从hbase中提取数据,也可以使用rest将数据推送到hbase。如果一个程序用于拉取数据,则另一个推送数据的程序将失败,反之亦然。
我打字解决了这个问题
jps
(您也可以使用ps -a
)找到与节俭过程相对应的数字。然后我用kill 12345
. 之后,我在后台通过键入./hbase-daemon.sh start thrift
. 之后,我的程序可以成功地从数据库中提取数据,但我的另一个插入数据的程序停止工作。代码没有问题,问题是rest和thrift不能同时在同一台服务器上工作。