一种窄带物联网NB-IoT系统的制作方法

一种窄带物联网nb-iot系统
技术领域
1.本发明涉及物联网技术领域，特别涉及一种窄带物联网nb-iot系统。


背景技术：

2.窄带物联网(narrow band internet of things，nb-iot)成为万物互联网络的一个重要分支，自从被纳入3gpp国际标准后，在物联网行业中得到了高速的发展。nb-iot支持低功耗设备在广域网的蜂窝数据连接，也被叫作低功耗广域网(low-power wide-area network，lpwan)。nb-iot支持待机时间长、对网络连接要求较高设备的高效连接。nb-iot设备能提供非常全面的室内蜂窝数据连接覆盖。nb-iot构建于蜂窝网络，只消耗大约180khz的带宽，可直接部署于全球移动通信系统(global system for mobile communication，gsm)网络、通用移动通信系统(universal mobile telecommunications system，umts)网络或长期演进技术(long term evolution，lte)网络，以降低部署成本、实现平滑升级。
3.国际移动通信系统2020(international mobile telecom system 2020，imt2020)推进组在5g的远景需求规划中提出未来5g网络中连接密度可能达到100万连接每平方公里，下一代移动网络联盟(next generation mobile networks alliance，ngmn联盟)在5g白皮书中也提出对单个运营商来说，每平方公里的俩呢及密度可达到20万，这意味着对于物联网来说，设备连接的数字会呈现出爆发式增长，甚至可能更多。
4.但是目前常见的窄带物联网数据落地数据库选择基本上都是类似mysql、mongodb、hbase等等国外开源数据库，为了推进软件和系统的国产化运行，就需要随时切换数据库的情景，而目前市场上各种数据库之间的适配存在不一致性，因此需要一种融合多种数据库的nb-iot系统。


技术实现要素：

5.本发明实施例提供一种窄带物联网nb-iot系统，用以解决现有技术中，各种数据库之间的适配存在不一致性，而无法进行数据库切换的问题。
6.为了解决上述技术问题，本发明实施例提供如下技术方案：
7.本发明实施例提供一种窄带物联网nb-iot系统，包括：
8.用户接口模块，用于接收用户输入的配置信息；
9.云平台接入模块，与终端设备连接，所述云平台接入模块用于接收所述终端设备发送的上行数据；
10.物模型模块，与所述用户接口模块和所述云平台接入模块连接，所述物模型模块用于根据物模型格式对所述云平台接入模块发送的上行数据进行解析，得到开源数据；所述上行数据是所述终端设备向所述云平台接入模块发送的；所述配置信息包括所述物模型格式；
11.落地服务模块，与所述物模型模块以及至少一个数据库连接，所述落地服务模块用于根据所述物模型模块发送的所述配置信息以及所述数据库，对所述开源数据进行数据
源处理以及数据落地；所述配置信息是所述用户接口模块向所述物模型模块发送的。
12.可选地，所述配置信息包括数据源配置信息和落地信息。
13.可选地，所述数据源配置信息包括：数据库驱动信息、数据库统一资源标志符信息、数据库模式信息、用户账号和连接密码。
14.可选地，所述落地信息包括：落地间隔信息、落地数据条数信息和落地触发方案。
15.可选地，还包括：
16.鉴权模块，与所述云平台接入模块连接；
17.在所述终端设备向所述云平台接入模块发送所述上行数据之前，所述鉴权模块用于根据所述云平台接入模块发送的登陆信息对所述终端设备进行鉴权；
18.其中，所述登陆信息是所述终端设备向所述云平台接入模块发送的。
19.可选地，还包括：
20.开源中间件模块；所述落地服务模块，通过所述开源中间件模块与所述物模型模块连接；
21.所述配置信息和所述开源数据是所述物模型模块通过所述开源中间件模块，向所述落地服务模块发送的。
22.可选地，还包括：
23.数据存储模块，与所述云平台接入模块连接，以及通过中间件模块与所述落地服务模块连接；
24.所述数据存储模块用于存储云平台接入模块发送的，所述终端设备的登陆信息和登出信息，并将所述登陆信息和所述登出信息通过所述中间件模块发送至所述落地服务模块连接；
25.其中，所述登出信息是所述终端设备向所述云平台接入模块发送的。
26.可选地，落地服务模块对所述开源数据进行数据源处理以及数据落地，包括：
27.所述落地服务模块对所述开源数据进行数据处理，得到处理后的开源数据；
28.所述落地服务模块对所述处理后的开源数据进行解析，得到终端设备的设备报文消息；
29.所述落地服务模块根据所述设备报文消息中的数据源身份标识信息，确定所述数据源身份标识信息对应的目标数据源；
30.所述落地服务模块根据所述目标数据源对所述处理后的开源数据进行分流，得到分流数据；
31.所述落地服务模块根据所述落地信息以及所述目标数据源对所述分流数据进行数据落地。
32.可选地，落地服务模块对所述开源数据进行数据源处理包括以下至少之一：
33.所述落地服务模块对所述开源数据进行数据源添加；
34.所述落地服务模块对所述开源数据进行数据源修改；
35.所述落地服务模块对所述开源数据进行数据源切换。
36.可选地，所述落地服务模块对所述开源数据进行数据源切换，包括：
37.修改所述开源数据的数据源加载逻辑；
38.对所述开源数据进行由默认数据源切换至修改后的数据源加载逻辑对应的目标
数据源的处理。
39.可选地，所述落地服务模块根据所述设备报文消息中的数据源身份标识信息，确定所述数据源身份标识信息对应的目标数据源，包括：
40.所述落地服务模块根据所述数据源身份标识信息，确定当前是否缓存所述数据源身份标识信息对应的目标数据源；
41.在所述落地服务模块未缓存所述目标数据源的情况下，根据预设数据源创建方法生成所述目标数据源；
42.所述落地服务模块缓存所述目标数据源。
43.可选地，所述落地服务模块根据所述落地信息以及所述目标数据源对所述分流数据进行数据落地，包括：
44.所述落地服务模块根据所述落地信息以及所述目标数据源对所述分流数据进行批量数据落地。
45.本发明的有益效果是：
46.本发明方案，提供一种窄带物联网nb-iot系统，包括用于接收用户输入的配置信息的用户接口模块、用于接收终端设备发送的上行数据的云平台接入模块，用于根据预设的物模型格式对所述云平台接入模块发送的上行数据进行解析，得到开源数据的物模型模块，以及对开源数据进行数据源处理以及数据落地的落地服务模块，该落地服务模块与至少一个数据库连接，可适应用户切换数据库的场景。
附图说明
47.图1表示本发明实施例提供的窄带物联网nb-iot系统的框架图；
48.图2表示本发明实施例提供的云平台接入模块的框架图；
49.图3表示本发明实施例提供的终端设备接入窄带物联网nb-iot系统的流程图。
具体实施方式
50.为使本发明的目的、技术方案和优点更加清楚，下面将结合附图及具体实施例对本发明进行详细描述。
51.本发明针对现有技术中，各种数据库之间的适配存在不一致性，而无法进行数据库切换的问题，提供一种窄带物联网nb-iot系统。
52.如图1所示，本发明实施例提供一种窄带物联网nb-iot系统，包括：
53.用户接口模块，用于接收用户输入的配置信息；
54.云平台接入模块，与终端设备连接，所述云平台接入模块用于接收所述终端设备发送的上行数据；
55.物模型模块，与所述用户接口模块和所述云平台接入模块连接，所述物模型模块用于根据物模型格式对所述云平台接入模块发送的上行数据进行解析，得到开源数据；所述上行数据是所述终端设备向所述云平台接入模块发送的；所述配置信息包括所述物模型格式；
56.落地服务模块，与所述物模型模块以及至少一个数据库连接，所述落地服务模块用于根据所述物模型模块发送的所述配置信息以及所述数据库，对所述开源数据进行数据
源处理以及数据落地；所述配置信息是所述用户接口模块向所述物模型模块发送的。
57.请参阅图1，本发明实施例提供的窄带物联网nb-iot系统，包括：用户接口模块(nbiot-api)，用户接口模块nbiot-api提供资源配置接口，用户通过接口配置相应的配置信息。用户通过nbiot-api为终端设备设置待下发的命令并用于直接下发命令。
58.窄带物联网nb-iot系统还包括用于终端设备接入的云平台接入模块(nbiot-acc)，云平台接入模块nbiot-acc用于终端设备登陆登出、数据上下行处理与传输，也就是nbiot-acc用于接收终端设备发送的登陆信息、登出信息、上行数据，以及传输下行数据。
59.具体地，云平台接入模块nbiot-acc的框架图如图2所示，包括受限应用协议(constrained application protocol，coap)占，即coap协议栈，coap协议栈包括用于通过nb-iot核心网络接入device(终端设备)的connector(连接器)，messageinterception(消息拦截)，matcher(匹配界面)，reliabilitylayer(可靠性层)，blockwiselayer(块状层)，observelayer(观察层)，以及交换清理层(exchangecleanuplayer)，云平台接入模块nbiot-acc还包括与coap协议栈连接的messagedeliver(轻型消息工具)，以及消息处理单元，其中，消息处理单元包括log_in(登陆)、keep-alive(保持状态)、thing_data(数据)和cmd(命令提示符)等工具。云平台接入模块nbiot-acc还包括与消息处理单元连接的接入机内部服务，接入及内部服务包括：session(会话控制)、设备连接/未连接(dev_on/offline)、模型(thing_model)、zookeeper(分布式应用程序协调服务软件)、dubbo框架和auth_service(认证服务)等工具。
60.窄带物联网nb-iot系统还包括用于对终端设备发送的上行数据解码的物模型模块(thing-model)，具体地，物模型模块thing-model用于校验云平台接入模块nbiot-acc发送的上行数据，若校验成功，将上行数据按照用户配置的配置信息中的物模型格式进行解析，得到开源数据(kafka数据)。
61.窄带物联网nb-iot系统还包括用于处理数据源和进行数据点落地等功能的落地服务模块(nbiot-storage)，且落地服务模块nbiot-storage连接至少一个数据库，可选地，数据库包括：mongodb、达梦数据库(dmsql)和关系型数据库(mysql)，上述的数据库持久化存储终端设备的数据，包括终端设备上下线、属性上报等信息。
62.本发明实施例提供的窄带物联网nb-iot系统能够支持动态切换以及支持持久化、多方式加载数据源，可适应用户频繁切换不同数据库的场景，并且本发明提供的窄带物联网nb-iot系统充分考虑到国产化进程，能够支持达梦数据库等国产数据库的灵活切换。
63.可选地，所述配置信息包括数据源配置信息和落地信息。
64.需要说明的是，用户通过接口配置相应的配置信息，其中包括配置相应的数据源(数据源配置信息)，以及配置批量落地相应的参数(落地信息)。
65.可选地，所述数据源配置信息包括：数据库驱动信息、数据库统一资源标志符信息、数据库模式信息、用户账号和连接密码。
66.也就是，用户通过接口配置相应的数据源包括但不限于数据库驱动信息、数据库统一资源标志符信息(数据库uri)、相应的数据库模式信息(模式schema)、用户账号和连接密码等。
67.可选地，所述落地信息包括：落地间隔信息、落地数据条数信息和落地触发方案。
68.也就是，用户通过接口配置批量落地相应的参数包括但是不限于落地间隔(落地
间隔信息)、落地数据条数(落地数据条数信息)和落地触发方案。
69.用户接口模块nbiot-api用于用户设置终端设备下发的命令和直接下发的命令，同时，可通过网络接口创建、修改数据源，配置落地规则。
70.可选地，还包括：
71.鉴权模块，与所述云平台接入模块连接；
72.在所述终端设备向所述云平台接入模块发送所述上行数据之前，所述鉴权模块用于根据所述云平台接入模块发送的登陆信息对所述终端设备进行鉴权；
73.其中，所述登陆信息是所述终端设备向所述云平台接入模块发送的。
74.请继续参阅图1，窄带物联网nb-iot系统还包括用于终端设备鉴权的鉴权模块(auth-service)，也就是，终端设备的登陆登出等行为通过鉴权模块auth-service进行鉴权。
75.具体来说，在终端设备唤醒后，终端设备连接云平台接入模块nbiot-acc，云平台接入模块nbiot-acc调用鉴权模块auth-service提供的grpc接口，对终端设备进行鉴权，查看终端设备是否合法，合法则连接成功，云平台接入模块nbiot-acc开始接收终端设备发送的上行数据，以及下发下行数据，若不合法则拒绝终端设备的连接。也就是，鉴权模块auth-service用于将终端设备发送的登陆信息、登出信息、保活报文的鉴权信息发送给云平台接入模块nbiot-acc。
76.可选地，还包括：
77.开源中间件模块；所述落地服务模块，通过所述开源中间件模块与所述物模型模块连接；
78.所述配置信息和所述开源数据是所述物模型模块通过所述开源中间件模块，向所述落地服务模块发送的。
79.请继续参阅图1，落地服务模块nbiot-storage通过开源中间件模块(kafka)与物模型模块thing-model连接，开源中间件模块kafka用于内部模块间数据通信，物模型模块thing-model将上行数据按照用户配置的配置信息中的物模型格式进行解析，得到的开源数据(kafka数据)发送至开源中间件模块kafka，进而使落地服务模块nbiot-storage进行数据落地服务消费落库。
80.进一步地，云平台接入模块nbiot-acc与鉴权模块auth-service和物模型模块thing-model之间分别通过远程过程调用(remote procedure call，rpc)中间件连接，物模型模块thing-model和用户接口模块nbiot-api之间也通过rpc中间件连接，本发明实施例提供的窄带物联网nb-iot系统将kafka和rpc作为模块之间的同步通信中间件，可以降低模块与模块之间的耦合度，实现模块间的解耦和异步通信，便于各个模块的独立运行和扩展维护。
81.可选地，还包括：
82.数据存储模块，与所述云平台接入模块连接，以及通过中间件模块与所述落地服务模块连接；
83.所述数据存储模块用于存储云平台接入模块发送的，所述终端设备的登陆信息和登出信息，并将所述登陆信息和所述登出信息通过所述中间件模块发送至所述落地服务模块连接；
84.其中，所述登出信息是所述终端设备向所述云平台接入模块发送的。
85.请继续参阅图1，窄带物联网nb-iot系统还包括用于维护注册信息及订阅信息的数据存储模块(nbiot-session)，云平台接入模块nbiot-acc将终端设备的信息(登陆信息和登出信息)以及上行数据的鉴权信息存储于数据存储模块nbiot-session。
86.具体来说，数据存储模块nbiot-session用于在终端设备通过云平台接入模块nbiot-acc成功接入到窄带物联网nb-iot系统的云平台后，，缓存该终端设备的相关状态(如订阅信息)和对应的接入模块地址，并将设备的上线信息、主动下线信息及被动下线信息(t_loginout)发送至相关处理业务。
87.需要说明的是，窄带物联网nb-iot系统的云平台系统包括：鉴权模块auth-service、物模型模块thing-model、数据存储模块nbiot-session、落地服务模块nbiot-storage和用户接口模块nbiot-api。
88.可选地，落地服务模块对所述开源数据进行数据源处理以及数据落地，包括：
89.所述落地服务模块对所述开源数据进行数据处理，得到处理后的开源数据；
90.所述落地服务模块对所述处理后的开源数据进行解析，得到终端设备的设备报文消息；
91.所述落地服务模块根据所述设备报文消息中的数据源身份标识信息，确定所述数据源身份标识信息对应的目标数据源；
92.所述落地服务模块根据所述目标数据源对所述处理后的开源数据进行分流，得到分流数据；
93.所述落地服务模块根据所述落地信息以及所述目标数据源对所述分流数据进行数据落地。
94.具体来说，云平台接入模块nbiot-acc记录终端设备的上下线数据以及每次终端设备上报的上行数据并发送相应的开源数据(kafka数据)，落地服务模块nbiot-storage消费并解析kafka数据，得到kafka数据中的设备报文消息，并根据设备报文消息内容当中的数据源身份标识信息(resource_id)分流、缓存到内存管道当中(分流数据)，然后根据resource_id选择、生成相应的目标数据源，最后将目标数据源加载到当前上下文中，并批量地对分流数据进行落地操作。
95.可选地，落地服务模块对所述开源数据进行数据源处理包括以下至少之一：
96.所述落地服务模块对所述开源数据进行数据源添加；
97.所述落地服务模块对所述开源数据进行数据源修改；
98.所述落地服务模块对所述开源数据进行数据源切换。
99.也就是，落地服务模块nbiot-storage用于添加数据源、修改数据源以及数据源的切换中的至少之一。
100.下面结合图3，说明终端设备接入窄带物联网nb-iot系统的流程。
101.终端设备通过云平台接入模块nbiot-acc登陆，生成鉴权信息(sastoken)，终端设备携带sastoken，发起登陆请求，鉴权模块auth-service对终端设备进行鉴权，并判断终端设备是否合法，在鉴权不合法的情况下，终端设备结束接入流程，在鉴权合法的情况下，终端设备更新会话控制(session)当中的标记(token)，终端设备向云平台接入模块nbiot-acc发送上行数据，物模型模块thing-model根据上行数据生成开源数据(kafka数据)，并发
送开源数据(kafka数据)至落地服务模块nbiot-storage根据kafka数据中设备报文消息的数据源身份标识信息(resource_id)选择目标数据源，若不能，则丢弃数据并打印相应日志，结束终端设备接入流程，若能，根据不同的目标数据源分流kafka数据，并根据落地条件批量落地，结束终端设备接入进程。
102.可选地，所述落地服务模块对所述开源数据进行数据源切换，包括：
103.修改所述开源数据的数据源加载逻辑；
104.对所述开源数据进行由默认数据源切换至修改后的数据源加载逻辑对应的目标数据源的处理。
105.落地服务模块nbiot-storage动态切换数据源并批量落地数据的方法如下：
106.落地服务模块nbiot-storage首先以一定的格式从开源数据(kafka数据)消费的设备报文消息，获取设备报文消息当中的数据源身份标识信息(resource_id)，然后通过调用并重写spring-jdbc包当中abstractroutingdatasource类的determinetargetdatasource以及determinecurrentlookupkey方法以修改数据源加载逻辑，abstractroutingdatasource类可以充当datasource的路由中介，能有在运行时，根据某种key值来动态切换到真正的datasource(目标数据源)上。
107.进一步地，所述落地服务模块根据所述设备报文消息中的数据源身份标识信息，确定所述数据源身份标识信息对应的目标数据源，包括：
108.所述落地服务模块根据所述数据源身份标识信息，确定当前是否缓存所述数据源身份标识信息对应的目标数据源；
109.在所述落地服务模块未缓存所述目标数据源的情况下，根据预设数据源创建方法生成所述目标数据源；
110.所述落地服务模块缓存所述目标数据源。
111.需要说明的是，修改数据源加载逻辑有两种方法：
112.一种是只重写determinecurrentlookupkey方法：
113.通过重写determinecurrentlookupkey方法，从一个自定义的方法当中获取数据源key值，这样在我们想动态切换数据源的时候，只要通过这个自定义方法提供相应key就可以动态改变数据源了。
114.这种方式要求在获取数据源之前，要先进行初始化，将需要的各个数据源提前存入到预配置的一个数据源配置表resolveddatasources中。
115.另一种是重写determinetargetdatasource：
116.因为数据源就是在这个方法查询创建并返回的，即该方法为数据源创建方法，通过重写这个方法可以更加自由，通过重写后的方法返回一个共用的datasource的实现类，可以在任何希望的地方读取数据源信息。包括但不限于从数据库、本地文件、网络接口等方式读取加载数据源信息，然后只需创建相应的数据源对象就可以了。
117.在本发明实施例中，具体说明更加灵活的重写determinetargetdatasource的方法，在获取上行数据后，根据数据源身份标识信息(resource_id)首先在内部缓存表中查询是否存在相应的目标数据源，若内部缓存表中不存在相应数据源，则调用数据源创建方法(预设数据源创建方法)生成并验证目标数据源，验证通过后存入内部缓存表中。
118.进一步地，所述落地服务模块根据所述落地信息以及所述目标数据源对所述分流
数据进行数据落地，包括：
119.所述落地服务模块根据所述落地信息以及所述目标数据源对所述分流数据进行批量数据落地。
120.在落地服务模块nbiot-storage确定目标数据源后，根据resource_id区分不同的开源数据，分别缓存进对应的内部管道当中(分流数据)，根据用户配置的条件分时、分量、分触发条件批量的进行数据落地。
121.需要说明的是，本发明实施例使用jdbc数据源规范，mongodb数据库需要对mongo-java-driver数据源进行转义，或使用各种mongo-jdbc开源项目。
122.本发明实施例提供的窄带物联网nb-iot系统，数据库之间的切换，只需初始对应的连接所需要的连接池，基本没有其他开销，并且提供一种可以向不同种类数据库之中落地数据的方法，同时支持数据批量落地，减少频繁创建连接的网络开销，用户可以根据自身需求，灵活控制落地数据的间隔、每次落地的数据量以及数据落地触发条件，各服务间配置共享且无状态化，能实现分布式部署和水平扩展，避免性能瓶颈，与各相关服务实现业务松耦合，降低云平台接入模块业务复杂度，方便实现接入服务功能扩展和限流统计等。
123.以上所述的是本发明的优选实施方式，应当指出对于本技术领域的普通人员来说，在不脱离本发明所述的原理前提下还可以作出若干改进和润饰，这些改进和润饰也在本发明的保护范围内。

技术特征：
1.一种窄带物联网nb-iot系统，其特征在于，包括：用户接口模块，用于接收用户输入的配置信息；云平台接入模块，与终端设备连接，所述云平台接入模块用于接收所述终端设备发送的上行数据；物模型模块，与所述用户接口模块和所述云平台接入模块连接，所述物模型模块用于根据物模型格式对所述云平台接入模块发送的上行数据进行解析，得到开源数据；所述上行数据是所述终端设备向所述云平台接入模块发送的；所述配置信息包括所述物模型格式；落地服务模块，与所述物模型模块以及至少一个数据库连接，所述落地服务模块用于根据所述物模型模块发送的所述配置信息以及所述数据库，对所述开源数据进行数据源处理以及数据落地；所述配置信息是所述用户接口模块向所述物模型模块发送的。2.根据权利要求1所述的窄带物联网nb-iot系统，其特征在于，所述配置信息包括数据源配置信息和落地信息。3.根据权利要求2所述的窄带物联网nb-iot系统，其特征在于，所述数据源配置信息包括：数据库驱动信息、数据库统一资源标志符信息、数据库模式信息、用户账号和连接密码。4.根据权利要求2所述的窄带物联网nb-iot系统，其特征在于，所述落地信息包括：落地间隔信息、落地数据条数信息和落地触发方案。5.根据权利要求1所述的窄带物联网nb-iot系统，其特征在于，还包括：鉴权模块，与所述云平台接入模块连接；在所述终端设备向所述云平台接入模块发送所述上行数据之前，所述鉴权模块用于根据所述云平台接入模块发送的登陆信息对所述终端设备进行鉴权；其中，所述登陆信息是所述终端设备向所述云平台接入模块发送的。6.根据权利要求1所述的窄带物联网nb-iot系统，其特征在于，还包括：开源中间件模块；所述落地服务模块，通过所述开源中间件模块与所述物模型模块连接；所述配置信息和所述开源数据是所述物模型模块通过所述开源中间件模块，向所述落地服务模块发送的。7.根据权利要求1所述的窄带物联网nb-iot系统，其特征在于，还包括：数据存储模块，与所述云平台接入模块连接，以及通过中间件模块与所述落地服务模块连接；所述数据存储模块用于存储云平台接入模块发送的，所述终端设备的登陆信息和登出信息，并将所述登陆信息和所述登出信息通过所述中间件模块发送至所述落地服务模块连接；其中，所述登出信息是所述终端设备向所述云平台接入模块发送的。8.根据权利要求1所述的窄带物联网nb-iot系统，其特征在于，落地服务模块对所述开源数据进行数据源处理以及数据落地，包括：所述落地服务模块对所述开源数据进行数据处理，得到处理后的开源数据；所述落地服务模块对所述处理后的开源数据进行解析，得到终端设备的设备报文消息；
所述落地服务模块根据所述设备报文消息中的数据源身份标识信息，确定所述数据源身份标识信息对应的目标数据源；所述落地服务模块根据所述目标数据源对所述处理后的开源数据进行分流，得到分流数据；所述落地服务模块根据所述落地信息以及所述目标数据源对所述分流数据进行数据落地。9.根据权利要求1所述的窄带物联网nb-iot系统，其特征在于，落地服务模块对所述开源数据进行数据源处理包括以下至少之一：所述落地服务模块对所述开源数据进行数据源添加；所述落地服务模块对所述开源数据进行数据源修改；所述落地服务模块对所述开源数据进行数据源切换。10.根据权利要求9所述的窄带物联网nb-iot系统，其特征在于，所述落地服务模块对所述开源数据进行数据源切换，包括：修改所述开源数据的数据源加载逻辑；对所述开源数据进行由默认数据源切换至修改后的数据源加载逻辑对应的目标数据源的处理。11.根据权利要求8所述的窄带物联网nb-iot系统，其特征在于，所述落地服务模块根据所述设备报文消息中的数据源身份标识信息，确定所述数据源身份标识信息对应的目标数据源，包括：所述落地服务模块根据所述数据源身份标识信息，确定当前是否缓存所述数据源身份标识信息对应的目标数据源；在所述落地服务模块未缓存所述目标数据源的情况下，根据预设数据源创建方法生成所述目标数据源；所述落地服务模块缓存所述目标数据源。12.根据权利要求8所述的窄带物联网nb-iot系统，其特征在于，所述落地服务模块根据所述落地信息以及所述目标数据源对所述分流数据进行数据落地，包括：所述落地服务模块根据所述落地信息以及所述目标数据源对所述分流数据进行批量数据落地。

技术总结
本发明提供了一种窄带物联网NB-IoT系统，所述窄带物联网NB-IoT系统包括：用户接口模块，用于接收用户输入的配置信息；云平台接入模块，与终端设备连接，用于接收所述终端设备发送的上行数据；物模型模块，与所述用户接口模块和所述云平台接入模块连接，用于根据物模型格式对所述云平台接入模块发送的上行数据进行解析，得到开源数据；所述配置信息包括所述物模型格式；落地服务模块，与所述物模型模块以及至少一个数据库连接，用于根据所述物模型模块发送的所述配置信息以及所述数据库，对所述开源数据进行数据源处理以及数据落地。本发明方案，落地服务模块与至少一个数据库连接，可适应用户切换数据库的场景。可适应用户切换数据库的场景。可适应用户切换数据库的场景。


技术研发人员：王文杰 陈成 李春 卓从彬
受保护的技术使用者：中国移动通信集团有限公司
技术研发日：2022.02.16
技术公布日：2023/8/28