2

経由で hbase に接続しようとしています。nodejs hbase モジュール。利用した

nodejsのhbaseモジュールをダウンロードし、エクスプレスを使用して受信リクエストを処理するnodejsスクリプトで以下のコードを実行しようとしています:- .......

app.post('/upload', function(req, res,next){
     var read_stream = fs.createReadStream(req.files.upload_file.path, {encoding: 'base64'});
              read_stream.on("data", function(data){
               // process.stdout.write(data);
                dataload(data);
              });
              read_stream.on("error", function(err){
                console.error("An error occurred: %s", err)
              });
              read_stream.on("close", function(){
                console.log("File closed.")
            });


}

function dataload(data){
 var hbase = require('hbase');


 var tableobj=hbase({ host: "{my server ip}", port: "8080" }).getTable('my_table1');
               sys.debug(tableobj);


                tableobj.create("my_column_family", function(err, success){
                    if(err)
                    {
                        sys.debug("error1");
                    }
                    else
                    {

                        this.getRow('my_row')
                        .put('my_column_family:my_column', data, function(err, success){
                            if(err)
                            {
                            sys.debug("error");
                            }
                            else
                            {
                            sys.debug("success");
                            }


                            });

                    }

                    });
}

直面した問題:-サーバーを再起動すると[つまり、cygwinコマンドプロンプトで「ノード{スクリプトjsファイル名}」を再度指定して、このスクリプトによって作成されたサーバー]、hbaseテーブルが再作成され、以前に挿入されたすべての行が削除されました。

4

0 に答える 0