使用【數據牛刀】輕鬆駕馭日增長100萬級的大流水數據表

来源:https://www.cnblogs.com/JiangMingFeng/archive/2019/07/31/DataNiuKnife.html
-Advertisement-
Play Games

【數據牛刀】是本人貢獻的一款提供大數據表自動分割、歸檔和清理過期數據的服務。它使用C# /.NET CORE實現,當前支持Mysql數據源,支持docker容器。 ...


【數據牛刀】是本人貢獻的一款提供大數據表自動分割、歸檔和清理過期數據的服務。它使用C# /.NET CORE實現,當前支持Mysql數據源以及在docker容器中運行。

項目地址:https://github.com/mfjiang/DataNiuKnife

 

核心功能:

1、通過簡單的配置,可管理任意多個資料庫節點上的大數據表的定期數據分割、歸檔和清理。

2、每日執行數據複製。

3、按指定天數移除過期數據。

4、按月歸檔數據。

 

希望使用此服務的大數據表,有如下要求:

  1. 數據表存在自增長ID;
  2. 數據表存在時間列,數據以時間順序增長;
  3. 數據表不存在外鍵約束;
  4. 提供一個擁有讀取數據表元數據和建表許可權的資料庫賬號;

配置示例:

{
"AppSettings": {
    "LogManPath": "/app/LogMan/"       
},
"MySqlClusterSettings": {
    "Nodes": [
        {    
           {
            "MysqlNode": {
                "ID":1,
                "IsSlave": false,
                "DataBasesName": "data_sharding_a",
                "ConnStr": "server=192.168.3.250;database=data_sharding_a;user=app_user;password=your pwd;charset=utf8;",
                "DevideFromNodeID": 0,
                "DevideDataSet": "table 1:hash key,table 2:hash key,table n:hash key",
                "AutoMoveDataSet": "table_name=data_shard,key_name=id,date_field=created,data_hold_days=180,archive_node_id=2,schedule_time=23:00:00;"
            }
        },
        {
            "MysqlNode": {
                "ID": 2,
                "IsSlave": false,
                "DataBasesName": "data_sharding_b",
                "ConnStr": "server=192.168.3.250;database=data_sharding_b;user=app_user;password=your pwd;charset=utf8;",
                "DevideFromNodeID": 0,
                "DevideDataSet": "",
                "AutoMoveDataSet": ""
            }
        }
    ]
},
"AllowedHosts": "*"
}

理解這一段配置:

"AutoMoveDataSet": "table_name=data_shard,key_name=id,date_field=created,data_hold_days=180,archive_node_id=2,schedule_time=23:00:00;"

table_name: 要列入自動管理的數據表名。

key_name: 主鍵名。 

date_field: 時間列名。 

data_hod_days: 數據保留期的天數。 

archive_node_id: 本配置中作為歸檔庫的資料庫節點ID。 

schedule_time: 每日運行的計劃時間。

 

如果一個DB節點有多個數據表要配置,只需用;號拼接配置行即可。

 

本服務可以在docker容器中運行:

docker build -f Dockfile -t data_niu_knife:demo .
docker run --name data_niu_knife_hosted --mount type=bind,source=/home/docker_data/DataNiuKnife/LogMan/,target=/app/LogMan/ -d data_niu_knife:demo .

 

正常運行後,可以看到類似如下日誌:

[root@localhost ~]# cat /home/docker_data/DataNiuKnife/LogMan/MysqlDataWorker-2019-07-29-pid1.log
====== DataNiuKnife.MysqlDataWorker Info 07/29/2019 11:00:00 ======
MysqlDataWorker已在服務環境啟動,源表名:data_shard
====== DataNiuKnife.MysqlDataWorker Info 07/29/2019 11:00:00 ======
開始自動創建分表,表名:data_shard_spt_201907
====== DataNiuKnife.MysqlDataWorker Info 07/29/2019 11:00:00 ======
開始創建分表:
CREATE TABLE IF NOT EXISTS `data_shard_spt_201907`   (
  `id` bigint(10) unsigned NOT NULL AUTO_INCREMENT,
  `value` varchar(255) DEFAULT NULL,
  `created` datetime NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=51 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci
====== DataNiuKnife.MysqlDataWorker Info 07/29/2019 11:00:01 ======
成功創建分表:data_shard_spt_201907
====== DataNiuKnife.MysqlDataWorker Info 07/29/2019 11:00:01 ======
成功自動創建分表,表名:data_shard_spt_201907
====== DataNiuKnife.MysqlDataWorker Info 07/29/2019 11:00:01 ======
開始自動複製數據,源表名:data_shard,分表名:data_shard_spt_201907
====== DataNiuKnife.MysqlDataWorker Info 07/29/2019 11:00:02 ======
自動複製了50筆數據,源表名:data_shard,分表名:data_shard_spt_201907

  


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 問道 面向Abp 在面向服務的時候,Session 幹嘛用? 先把Session 的作用說了,但是在微服務環境下給忽略了,相當於忽略了核心。 Session 只是個功能。就是根據Cookie 的SessionId 得到的一個KeyValue列表 實際上Session 就是一個緩存可以向寫東西,讀東西 ...
  • 之前做數據同步時,用過timer、window服務,現在不用那麼費事了,可以使用Quartz,並且配置靈活,使用cron表達式配置XML就可以。我用的是3.0.7版本支持.netcore。 首先創建一個.netcore控制台應用程式,添加Quartz、Quartz.Jobs、Quartz.Plugi ...
  • 1、元素屬性 XAML是一種聲明性語言,XAML編譯器會為每一個標簽創建一個與之對應的對象。對象創建出來之後要對它的屬性進行必要的初始化之後才有使用意義。因為XAML語言不能寫程式運行邏輯,所以一份XAML文檔除了使用標簽聲明對象,另外一個功能就是初始化對象的屬性了。在XAML中為對象屬性賦值共有兩 ...
  • 無論是哪種C/S技術,涉及數據可視化就非常的累贅了,當然大神也一定有,只不過面向大多數人,還是通過網頁來實現,有的時候不想把這兩個功能分開,一般會是客戶的原因,所以我們打算在WPF中嵌入WebBrowser,然後使用ECharts 完成複雜的圖表展示,其功能不亞於一個名為Devexpress的圖標庫 ...
  • 使用編譯器可以將C#代碼編譯為中間語言(Intermediate Language,IL)代碼,中間語言是一種平臺無關的指令集,最終會由CLR將中間語言位元組碼轉換為對應平臺的機器碼從而執行;閱讀IL代碼通常可以讓我們更好的瞭解C#的底層實現方式; ※中間語言又稱為通用中間語言(Common Inte ...
  • 問題 在使用 DevExpress 開發 WinForm 程式時,我是使用的預設皮膚進行開發。但客戶要求標題欄背景色改為藍色,標題文字顏色改為白色。 改顏色比較簡單,參考了 "DevExpress Support" 的說明,通過獲取皮膚更改 和 就可以實現。不過更改之後,發現在低分屏下麵,標題文字出 ...
  • 1、新建WPF項目 使用Visual Studio 代碼編輯器點擊新建項目,選擇 WPF應用後點擊下一步: 在新視窗中我們填寫項目名稱、選擇項目位置後點擊創建就完成了WPF項目的創建。 2、WPF項目分支介紹 Properties分支:裡面的主要內容是程式要用到的一些資源和配置信息。 引用(Refe ...
  • 做列印功能的時候,有的DIV界面的內容過多,以至於加上一個滾動條來達到滾動顯示剩餘的部分,但是在列印的時候會發現列印的預覽的界面只會顯示當前界面,超出的內容不會顯示,其實解決這個問題的辦法就是將滾動條隱藏掉就行。 這個是我在列印是的樣式 這個是我的界面 這個是超出的部分 使用overflow:hid ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...