From 0c01cc7017c5f8d96a91b763b849316565b608e9 Mon Sep 17 00:00:00 2001 From: MysticBoy Date: Wed, 5 Aug 2020 11:11:06 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E9=99=A4=E4=BA=86=E6=B2=A1=E5=BF=85?= =?UTF-8?q?=E8=A6=81=E7=9A=84=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- IoTSharp/Jobs/PushData.cs | 13 ++----------- 1 file changed, 2 insertions(+), 11 deletions(-) diff --git a/IoTSharp/Jobs/PushData.cs b/IoTSharp/Jobs/PushData.cs index 090db836..3262a0f6 100644 --- a/IoTSharp/Jobs/PushData.cs +++ b/IoTSharp/Jobs/PushData.cs @@ -21,7 +21,7 @@ using System.Threading.Tasks; namespace IoTSharp.Jobs { - [SilkierQuartz(0, "PushData", "Push Iot Message Data to DataBase ", TriggerGroup = "Data")] + [SilkierQuartz(1, "PushData", "Push Iot Message Data to DataBase ", TriggerGroup = "Data")] public class PushData : IJob { private readonly AppSettings _appSettings; @@ -69,16 +69,7 @@ namespace IoTSharp.Jobs break; case DataCatalog.TelemetryData: - switch (_appSettings.TelemetryStorage) - { - case TelemetryStorage.SingleTable: - await _storage.StoreTelemetryAsync(msg); - break; - case TelemetryStorage.Sharding: - break; - default: - break; - } + await _storage.StoreTelemetryAsync(msg); var result1 = await _dbContext.SaveAsync(msg.MsgBody, device, msg.DataSide); if (result1.exceptions?.Count > 0) { -- GitLab