{
    "dataSources": {
        "pageviews": {
            "spec": {
                "dataSchema": {
                    "dataSource": "pageviews",
                    "parser": {
                        "type": "string",
                        "parseSpec": {
                            "timestampSpec": {
                                "format": "auto",
                                "column": "time"
                            },
                            "dimensionsSpec": {
                                "dimensions": [
                                    "url",
                                    "user"
                                ]
                            },
                            "format": "json"
                        }
                    },
                    "granularitySpec": {
                        "type": "uniform",
                        "segmentGranularity": "hour",
                        "queryGranularity": "none"
                    },
                    "metricsSpec": [
                        {
                            "name": "views",
                            "type": "count"
                        },
                        {
                            "name": "latencyMs",
                            "type": "doubleSum",
                            "fieldName": "latencyMs"
                        }
                    ]
                },
                "ioConfig": {
                    "type": "realtime"
                },
                "tuningConfig": {
                    "type": "realtime",
                    "maxRowsInMemory": "100000",
                    "intermediatePersistPeriod": "PT10M",
                    "windowPeriod": "PT10M"
                }
            },
            "properties": {
                "task.partitions": "1",
                "task.replicants": "1"
            }
        }
    },
    "properties": {
        "zookeeper.connect": "localhost",
        "druid.discovery.curator.path": "/druid/discovery",
        "druid.selectors.indexing.serviceName": "druid/overlord",
        "http.port": "8200",
        "http.threads": "8"
    }

 1 /// <summary>
 2         /// 插入数据,基于服务端已经有的一个表pageviews
 3         /// </summary>
 4         [TestMethod]
 5         public void InsertData()
 6         {
 7             string url = "http://*.*.*.*:8200/v1/post/pageviews"; //发送数据
 8             string data = PostHttp(url, GetData());
 9             DruiExecuteResult result = JsonConvert.DeserializeObject<DruiExecuteResult>(data);
10 
11             Assert.IsTrue(result.result.received == "100");
12             Assert.IsTrue(result.result.received == "100");
13         }
14          public string GetData()
15         {
16             StringBuilder sb = new StringBuilder();
17             string temp = string.Empty;
18             string ISO8601time = string.Empty;
19             for (int i = 0; i < 100; i++)
20             {
21                 ISO8601time = DateTime.Now.ToString("yyyy-MM-ddTHH:mm:sszzzz", DateTimeFormatInfo.InvariantInfo);
22                 temp = "{\"time\":\"" + ISO8601time + "\",\"url\":\"test" + i.ToString() + "\",\"user\":\"hello" + i.ToString() + "\",\"latencyMs\":" + i.ToString() + "}";
23                 sb.AppendLine(temp);
24             }
25 
26             string result = sb.ToString();
27 
28             return result;
29         }
30           private static string PostHttp(string url, string body)
31         {
32             HttpWebRequest httpWebRequest = (HttpWebRequest)WebRequest.Create(url);
33             httpWebRequest.ContentType = "application/x-www-form-urlencoded;charset=UTF-8";
34             httpWebRequest.ContentType = "application/json";
35             //httpWebRequest.ContentType = "text/plain";
36 
37             httpWebRequest.Method = "POST";
38             httpWebRequest.Timeout = 30000;
39             httpWebRequest.KeepAlive = false;
40             byte[] btBodys = Encoding.UTF8.GetBytes(body);
41             httpWebRequest.ContentLength = btBodys.Length;
42             string responseContent = string.Empty;
43             HttpWebResponse httpWebResponse = null;
44             StreamReader streamReader = null;
45             try
46             {
47                 httpWebRequest.GetRequestStream().Write(btBodys, 0, btBodys.Length);
48                 httpWebResponse = (HttpWebResponse)httpWebRequest.GetResponse();
49                 streamReader = new StreamReader(httpWebResponse.GetResponseStream());
50                 responseContent = streamReader.ReadToEnd();
51             }
52             catch (Exception er)
53             {
54                 throw new Exception("执行出现异常:" + "数据:" + body, er);
55             }
56             finally
57             {
58                 if (httpWebResponse != null)
59                 {
60                     httpWebResponse.Close();
61                 }
62                 if (streamReader != null)
63                 {
64                     streamReader.Close();
65                 }
66                 httpWebRequest.Abort();
67             }
68 
69             return responseContent;
70         }