Menggunakan HBase untuk penyimpanan data dan pertanyaan dalam Beego

Menggunakan rangka kerja HBase dalam Beego untuk penyimpanan data dan pertanyaan

Dengan perkembangan berterusan era Internet, storan dan pertanyaan data menjadi semakin kritikal. Dengan kemunculan era data besar, pelbagai sumber data menduduki kedudukan penting dalam bidang masing-masing Pangkalan data bukan hubungan adalah pangkalan data dengan kelebihan yang jelas dalam penyimpanan dan pertanyaan data, dan HBase ialah pangkalan data bukan hubungan yang diedarkan berdasarkan Hadoop. Pangkalan data perhubungan. Artikel ini akan memperkenalkan cara menggunakan HBase untuk penyimpanan data dan pertanyaan dalam rangka kerja Beego.

1. Pengenalan kepada HBase

HBase ialah sistem pangkalan data berorientasikan lajur teragih, yang dilaksanakan berdasarkan hasil penyelidikan Bigtable Google. HBase menggunakan HDFS Hadoop sebagai sistem fail asas dan menggunakan teknologi MapReduce Hadoop untuk pemprosesan data kelompok. Ciri utama HBase ialah data disimpan pada sistem fail yang diedarkan, dengan skalabiliti tinggi, ketersediaan tinggi dan prestasi tinggi. Dalam HBase, data akan disimpan mengikut Rowkey boleh ditetapkan, dan Rowkey boleh digunakan untuk pertanyaan pantas, menyokong penyimpanan dan pembacaan data berskala besar.

2. Pengenalan kepada rangka kerja Beego

Beego ialah rangka kerja Web bahasa Go yang ringan dan berprestasi tinggi Konsep reka bentuknya ringkas, mudah digunakan dan pantas. Rangka kerja Beego menyediakan reka bentuk rangka kerja yang baik dan modul fungsi yang kaya, seperti Session, Cache, ORM, Swagger API, dll. Ia menyepadukan hampir semua ciri dan sangat mudah untuk membangunkan aplikasi web.

3. Gunakan rangka kerja Beego untuk menyambung ke HBase

Sebelum menggunakan rangka kerja Beego untuk menyambung ke HBase, anda perlu memasang persekitaran bahasa Go dan persekitaran HBase. Untuk langkah pemasangan, sila rujuk dokumen rasmi dan dokumen lain yang berkaitan.

Mula-mula, pasang pakej pergantungan yang berkaitan:

go get github.com/tsuna/gohbase
go get github.com/tsuna/gohbase/hrpc

Kemudian, tambahkan fungsi sambungan:

import (
    "github.com/tsuna/gohbase"
    "github.com/tsuna/gohbase/hrpc"
    "log"
)

func Connect() gohbase.Client {
    client := gohbase.NewClient("localhost")
    return client
}

Dalam kod di atas, gunakan fungsi gohbase.NewClinet() untuk mencipta yang baharu Contoh akhir dan pulangan klien HBase, yang merupakan contoh yang disambungkan ke pelayan HBase tempatan.

Seterusnya, kita boleh menggunakan kod berikut untuk melaksanakan operasi sisipan:

func Insert(client gohbase.Client, tableName string, row, column, value []byte) {
    putRequest, _ := hrpc.NewPutStr(context.Background(), tableName, string(row),
        map[string]map[string][]byte{
            "cf1": {
                string(column): value,
            },
        })
    client.Put(putRequest)
}

Kod di atas boleh memasukkan data ke dalam HBase menggunakan fungsi gohbase.Client.Put().

4. Query HBase menggunakan rangka kerja Beego

Idea asas untuk menanyakan data daripada HBase ialah pelanggan berinteraksi dengan Pelayan Wilayah: pelanggan meminta Master untuk RegionServer di mana data terletak, dan Master akan mengembalikan RegionServer yang sepadan, dan kemudian pelanggan mewujudkan sambungan dengan RegionServer dan menanyakan data yang diperlukan daripada RegionServer.

Apabila menggunakan HBase, pertanyaan data adalah sangat cekap dan sekumpulan data boleh dikembalikan dengan cepat Sebab utama ialah HBase akan mengisih data mengikut saiz RowKey, supaya data yang berkaitan akan disatukan. . Apabila membuat pertanyaan, anda hanya perlu menghantar RowKey untuk disoal kepada HBase sebagai julat untuk mendapatkan sekumpulan data hasil yang diperlukan.

Berikut ialah contoh kod untuk menanyakan HBase menggunakan rangka kerja Beego:

func Get(client gohbase.Client, tableName string, row []byte) (map[string]string, error) {
    getReq, _ := hrpc.NewGetStr(context.Background(), tableName, string(row))
    getResp, err := client.Get(getReq)

    if err != nil {
        log.Fatal(err.Error())
    }

    if len(getResp.Cells) == 0 {
        return nil, nil
    }

    result := make(map[string]string)
    for _, cell := range getResp.Cells {
        result[string(cell.Qualifier)] = string(cell.Value)
    }

    return result, nil
}

Dalam kod di atas, gunakan fungsi gohbase.Client.Get() untuk menanyakan data dalam HBase, mengembalikan GetResponse dan kemudian gunakan peta untuk menanyakan keputusan Tukar kepada pasangan nilai kunci.

5. Ringkasan

Artikel ini memperkenalkan cara menggunakan HBase untuk penyimpanan data dan pertanyaan dalam rangka kerja Beego, termasuk proses menyambung ke HBase, memasukkan data dan pertanyaan data. HBase mempunyai kelebihan besar dalam bidang storan pangkalan data bukan perhubungan, dan ia menyokong akses serentak yang tinggi serta storan dan pertanyaan data berskala besar. Rangka kerja Beego ialah rangka kerja Web berprestasi tinggi, mudah digunakan dan pantas Dengan menggunakan rangka kerja Beego, anda boleh membangunkan aplikasi Web dengan cepat dan mudah Menggabungkan dengan HBase boleh meningkatkan prestasi dan kestabilan aplikasi.

Atas ialah kandungan terperinci Menggunakan HBase untuk penyimpanan data dan pertanyaan dalam Beego. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!