0

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

4

1 に答える 1