1      private void button1_Click(object sender, EventArgs e)

 2         {

 3             //Application.StartupPath + "\\" + NextFile.Name

 4             Task.Run(() => { CreateDataToFile(); });

 5         }

 6         public void CreateDataToFile()

 7         {

 8             StringBuilder sb = new StringBuilder();

 9             StringBuilder sborder = new StringBuilder();

10             int flag = 1;

11             sborder.Append(@"cd E:\curl-7.50.3-win64-mingw\bin" + Environment.NewLine);

12             DateTime endDate = DateTime.Parse("2016-10-22");

13             for (int i = 1; i <= 10000; i++)//1w个点

14             {

15                 DateTime startDate = DateTime.Parse("2016-10-22").AddYears(-1);

16                 this.Invoke(new Action(() => { label1.Text = "生成第" + i + "个"; }));

17

18                 while (startDate <= endDate)//每个点生成一年数据,每分钟一条

19                 {

20                     if (flag > 100000)//大于10w分割一个文件

21                     {

22                         string filename = new Random(GetRandomSeed()).Next(900000000) + ".json";

23

24                         FileStream fs3 = new FileStream(Application.StartupPath + "\\testdata\\" + filename, FileMode.OpenOrCreate);

25                         StreamWriter sw = new StreamWriter(fs3, Encoding.GetEncoding("GBK"));

26                         sw.WriteLine(sb.ToString());

27                         sw.Close();

28                         fs3.Close();

29                         sb.Clear();

30                         flag = 1;

31                         sborder.Append(@"curl 172.17.1.15:9200/_bulk?pretty --data-binary @E:\Bin\Debug\testdata\" + filename + Environment.NewLine);

32

33                     }

34                     else

35                     {

36                         sb.Append("{\"index\":{\"_index\":\"meterdata\",\"_type\":\"autoData\"}}" + Environment.NewLine);

37                         sb.Append("{\"Mfid \":" + i + ",\"TData\":" + new Random().Next(1067500) + ",\"TMoney\":" + new Random().Next(1300) + ",\"HTime\":\"" + startDate.ToString("yyyy-MM-ddTHH:mm:ss") + "\"}" + Environment.NewLine);

38                         flag++;

39                     }

40                     startDate = startDate.AddMinutes(1);//

41                 }

42

43             }

44             sborder.Append("pause");

45             FileStream fs1 = new FileStream(Application.StartupPath + "\\testdata\\order.bat", FileMode.OpenOrCreate);

46             StreamWriter sw1 = new StreamWriter(fs1, Encoding.GetEncoding("GBK"));

47             sw1.WriteLine(sborder.ToString());

48             sw1.Close();

49             fs1.Close();

50             MessageBox.Show("生成完毕");

51

52         }

53         static int GetRandomSeed()

54         {//随机生成不重复的编号

55             byte[] bytes = new byte[4];

56             System.Security.Cryptography.RNGCryptoServiceProvider rng = new System.Security.Cryptography.RNGCryptoServiceProvider();

57             rng.GetBytes(bytes);

58             return BitConverter.ToInt32(bytes, 0);

59         }