c# - 使用 Azure 函数从事件中心将数据插入 Sql Server

Question

我正在使用 Azure 函数从事件中心将数据插入到 SQL Server 中。

我编写此代码是为了在 SQL Server 中插入数据，但我每次执行只能插入一条消息。

public static void Run(string[] eventHubMessages, TraceWriter log)
{

  SqlConnection cnn = new SqlConnection();
  cnn.ConnectionString = /* my connection string */;
  cnn.Open();

  log.Info("Connection open");

  foreach(var item in eventHubMessages)
  {
    if(item.StartsWith("{") && item.EndsWith("}"))
    {
       SqlCommand cmd = new SqlCommand("TelemetriaAttiva.ImportEvents", cnn); // call stored procedure
       cmd.Parameters.AddWithValue("Events", item);
       cmd.CommandType = CommandType.StoredProcedure;
       cmd.ExecuteNonQuery();
    }
  }
}

存储过程代码为:

CREATE PROCEDURE [TelemetriaAttiva].[ImportEvents]  @Events NVARCHAR(MAX)
AS  BEGIN 
INSERT INTO TelemetriaAttiva.Events (IDType, PayloadType, SerialNumber, Cid, 
Year, Month, Day, Hour, Minute, Second, Sid, InsDate, InsUser) 
SELECT idtype, payloadtype, serialnumber, cid, year, month, day, hour, 
minute, second, sid, insdate, insuser FROM OPENJSON(@Events)
WITH(
    IDType varchar(50) '$.idtype',
    PayloadType varchar(50) '$.payloadtype',
    SerialNumber varchar(50) '$.serialnumber',
    Cid varchar(50) '$.cid',
    Year varchar(50) '$.year',
    Month varchar(50) '$.month',
    Day varchar(50) '$.day',
    Hour varchar(50) '$.hour',
    Minute varchar(50) '$.minute',
    Second varchar(50) '$.second',
    Sid varchar(50) '$.sid',
    InsDate varchar(50) '$.insdate',
    InsUser varchar(100) '$.insuser'
) 
END 
GO

有人可以帮助我在 Sql Server 上插入事件中心内的所有数据吗？

非常感谢!

Answer 1

所以，看起来您可以尝试以下操作:

1. 将所有消息连接到一个 JSON 数组中，例如

   var items = $"[{string.Join(",", eventHubMessages)}]";
   

2. 通过一次调用将它们全部传递给存储过程(与现在相同的调用，但没有任何 foreach 循环)

   cmd.Parameters.AddWithValue("Events", items);
   

3. 调整存储过程以期望 JSON 中的项目数组而不是单个项目。