迁移 SQL Server 中的历史数据

TagData
：InfluxDB 中的测量。
TagName
：InfluxDB 中的标签键。在 SQL Server 中，它是标签表中的一列。
<tag>
：标签的名称。在 SQL Server 中，它显示在标签表的
TagName
列中。
S
：InfluxDB 中的标签键。它表示 SQL Server 中浮点表或字符串表的
Status
列。
状态
：SQL Server 中浮点表或字符串表的
Status
列中的状态（
C
、
D
、
E
、
S
或
U
）。
<FieldKey>
: 为 InfluxDB 定义的字段键，如
V_B
、
V_I
、
V_D
或
V_S
，分别表示布尔值、整型值、双精度值或字符串值。
<value>
：标签值。在 SQL Server 中，它显示在浮点表或字符串表的
Val
列中。如果 <FieldKey> 为 V_I（表示值为整数），则值应采用以下格式：
<value>i
。例如，
V_I=8i
。
M
：记号。在 SQL Server 中，它是浮点表或字符串表的列。如果没有标记，可以忽略 M 和 <MarkerValue>。
<MarkerValue>
: SQL Server 中浮点表或字符串表的“
标记
”列中的值（
B
、
E
、
S
或空白）。
<Timestamp>
：InfluxDB 中以 Unix 时间表示的数据点的时间戳。要构造时间戳，请使用 SQL Server 中浮点表或字符串表的
DateAndTime
和
Millitm
列。

TagData,TagName="system\Second",S="C" V_I=8i,M="B" 1465839830100400200

import "sql"
sql.from(
    driverName: "sqlserver", 
    dataSourceName: "sqlserver://sa:password123@10.224.1.1:1433?database=mydb", 
    query: "Select 'TagData' as _measurement, FORMAT(DATEADD(SECOND,DATEDIFF(SECOND,GETDATE(),GETUTCDATE()),DATEADD(MILLISECOND,Millitm,CAST(DateAndTime as datetime2))), 'yyyy-MM-ddTHH:mm:ss.fffZ') as _time, dbo.TagTable.TagName as TagName, COALESCE(NULLIF(dbo.FloatTable.Status,''),'C') as S,'V_I' as _field, dbo.FloatTable.Val as _value
            from dbo.TagTable
            Join dbo.FloatTable on  dbo.FloatTable.TagIndex = dbo.TagTable.TagIndex
            where dbo.TagTable.TagName = 'system\\Second'")
|> map(fn: (r) =>({r with _time: time(v:r._time)}))
|> map(fn: (r) =>({r with _value: int(v:r._value)}))
|>to(
       bucket: "HMIserver",
       org:"Rockwell")                
sql.from(
    driverName: "sqlserver", 
    dataSourceName: "sqlserver://sa:password123@10.224.1.1:1433?database=mydb", 
    query: "Select 'TagData' as _measurement, FORMAT(DATEADD(SECOND,DATEDIFF(SECOND,GETDATE(),GETUTCDATE()),DATEADD(MILLISECOND,Millitm,CAST(DateAndTime as datetime2))), 'yyyy-MM-ddTHH:mm:ss.fffZ') as _time, dbo.TagTable.TagName as TagName, COALESCE(NULLIF(dbo.FloatTable.Status,''),'C') as S,'M' as _field, dbo.FloatTable.Marker as _value
            from dbo.TagTable
            Join dbo.FloatTable on  dbo.FloatTable.TagIndex = dbo.TagTable.TagIndex
            where dbo.FloatTable.Marker <> ''")
|> map(fn: (r) =>({r with _time: time(v:r._time)}))
|>to(
       bucket: "HMIserver",
       org:"MyOrganization")

import "sql"
：导入
sql
包。该
sql
包提供的工具可用于处理 SQL 数据库中的数据。
sql.from()
：从 SQL 数据源检索数据。其具有以下参数：
driverName
：用于连接到 SQL 数据库的驱动程序。对于 SQL Server，它是
sqlserver
。
dataSourceName
：用于连接到 SQL 数据库的数据源名称（DNS）或连接字符串。它包括 SQL Server 的用户名、密码、主机地址、端口和数据库名称，所有这些内容都应根据您自己的需要进行编辑。
query
：对 SQL Server 数据库执行的查询。
脚本第一部分中的查询从
标签
表和
浮点
表中选择多个字段，其中
TagName
为
system\Second
，字段为
V_I
。然后，将重命名选定字段以匹配 InfluxDB 模式。
您应该根据自己的需要编辑示例脚本的标签表、浮点表或字符串表名称、字段键（
V_B
、
V_I
、
V_D
或
V_S
）以及标签名称。您可以添加多个相同类型的标签，并以“
or
”分隔，例如：
dbo.TagTable.TagName = 'tag1' or dbo.TagTable.TagName = 'tag2'
。
脚本的第二部分中的查询与第一部分类似，只是它从
浮点
表中选择字段
M
。
您应该根据自己的需要编辑示例脚本的表类型（浮点表或字符串表）。
映射
：函数，用于将每条记录中的
_time
字段从字符串转换为时间值，或将每条记录中的
_value
字段从字符串转换为整数。
您应该根据自己的需要编辑示例脚本的值类型（
int
、
bool
、
float
或
string
）。
目标
：函数，用于将数据写入组织
MyOrganization
中的 InfluxDB 时段
HMIserver
。
您应通过输入自己的时段和组织来编辑示例脚本。要迁移到内置的 InfluxDB，组织名称必须是
Rockwell
;要迁移到外部 InfluxDB，可以自定义组织名称。