昨日、コードが動作し、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) をセットアップしたことだけです。それが問題ですか?必要なのは、データベースからデータを取得することだけです。