Hi,
also ich baue das Ganze über eine .bat Datei in csproj-Ordner wie folgt:
C:\Windows\Microsoft.NET\Framework64\v4.0.30319\MSBuild.exe /target:APDeployFull /p:Configuration=Release
und in der csproj dann im Target "APDeployFull"
<MSBuild Projects="Main.Administration.csproj" Targets="Clean;Build" StopOnFirstFailure="true" />
Der Abschnitt in dem ich die Daten von der Datenbank abrufe sieht so aus:
List<System.Threading.Tasks.Task> collectData = new List<System.Threading.Tasks.Task>();
for (int i = 0; i < endpoints.Count; i++)
{
if (showCalls || showBilltime)
{
if (ChartScale.Hour == chartScale)
{
collectData.Add(System.Threading.Tasks.Task.Factory.StartNew(new Action(endpoints.ElementAt(i).GetCallsAndBilltimeByHour)));
}
else if (ChartScale.Day == chartScale)
{
collectData.Add(System.Threading.Tasks.Task.Factory.StartNew(new Action(endpoints.ElementAt(i).GetCallsAndBilltimeByDay)));
}
else if (ChartScale.Month == chartScale)
{
collectData.Add(System.Threading.Tasks.Task.Factory.StartNew(new Action(endpoints.ElementAt(i).GetCallsAndBilltimeByMonth)));
}
else // Year
{
collectData.Add(System.Threading.Tasks.Task.Factory.StartNew(new Action(endpoints.ElementAt(i).GetCallsAndBilltimeByYear)));
}
}
if (showConcurrent)
{
collectData.Add(System.Threading.Tasks.Task.Factory.StartNew(new Action(endpoints.ElementAt(i).GetConcurrentCalls)));
}
}
// Collect values in parallel
System.Threading.Tasks.Task.WaitAll(collectData.ToArray());
Die Funktion, die dann letztlich während des Abholens aufgerufen wird, sieht exemplarisch so aus (die anderen wie GetConcurrentCalls, etc rufen Funktionen auf die genauso aussehen, nur eine andere Prozedur aufrufen):
internal static LinkedList<KeyValuePair<DateTime, object[]>> GetAdmCallsAndBilltimeByDay(DateTime dateStart, DateTime dateEnd, Enums.Accumulation accumulation, Enums.Endpoint endpoint)
{
LinkedList<KeyValuePair<DateTime, object[]>> values = new LinkedList<KeyValuePair<DateTime, object[]>>();
using (Npgsql.NpgsqlConnection connection = new Npgsql.NpgsqlConnection(ConfigurationManager.ConnectionStrings["voipDirectConnection"].ConnectionString))
{
using (Npgsql.NpgsqlCommand command = new Npgsql.NpgsqlCommand("web_adm_calls_and_billtime_by_day", connection))
{
command.CommandType = System.Data.CommandType.StoredProcedure;
command.CommandTimeout = 120;
try
{
command.Parameters.Add("p_date_start", NpgsqlTypes.NpgsqlDbType.TimestampTZ).Value = dateStart.ToUniversalTime();
command.Parameters.Add("p_date_end", NpgsqlTypes.NpgsqlDbType.TimestampTZ).Value = dateEnd.ToUniversalTime();
command.Parameters.Add("p_accumulation", NpgsqlTypes.NpgsqlDbType.Varchar).Value = accumulation.GetName();
command.Parameters.Add("p_endpoint", NpgsqlTypes.NpgsqlDbType.Varchar).Value = endpoint.GetName();
connection.Open();
using (Npgsql.NpgsqlDataReader dr = command.ExecuteReader())
{
while (dr.Read())
{
TimeSpan billtime;
int calls = 0;
calls = (int)dr.GetInt64(0);
billtime = new TimeSpan(dr.GetInterval(1).Ticks);
DateTime key = new DateTime(dr.GetDate(2).Year, dr.GetDate(2).Month, dr.GetDate(2).Day);
values.AddLast(new KeyValuePair<DateTime, object[]>(key, new object[] { billtime, calls }));
}
}
}
catch (Exception e)
{
Logger.Error(e, typeof(Node));
throw e;
}
finally
{
connection.Close();
}
}
}
return values;
}
und zumindest die Funktion ist static, könnte dies der Grund sein?
Nachdem ich alle Werte abgeholt habe, befülle ich dann die Charts
// Populate Series
collectData.Clear();
foreach (var item in populations)
{
collectData.Add(System.Threading.Tasks.Task.Factory.StartNew(new Action(item.Do)));
}
System.Threading.Tasks.Task.WaitAll(collectData.ToArray());
was beispielsweise so aussieht:
private void DoHour()
{
LinkedList<KeyValuePair<int, object[]>> callsAndBilltimeValues = this._endpoint.Hours;
// check if values from 0 to 23 are specified or add if missing
for (int i = 0; i < 24; i++)
{
try
{
callsAndBilltimeValues.Where(ca => ca.Key == i).Single();
}
catch
{
object[] o = new object[2] { 0, 0 };
KeyValuePair<int, object[]> newKvp = new KeyValuePair<int, object[]>(i, o);
callsAndBilltimeValues.AddLast(newKvp);
}
}
using (IEnumerator<KeyValuePair<int, object[]>> e = callsAndBilltimeValues.OrderBy(ca => ca.Key).GetEnumerator())
{
while (e.MoveNext())
{
string hour = e.Current.Key.ToString();
TimeSpan? billTime = e.Current.Value[0] as TimeSpan?;
int totalCalls = (int)e.Current.Value[1];
if (SeriesType.BillTime == this._type)
{
if (billTime.HasValue)
{
this._series.Points.AddXY(hour, Math.Round(billTime.Value.TotalHours));
}
else
{
this._series.Points.AddXY(hour, 0);
}
}
else if (SeriesType.Calls == this._type)
{
this._series.Points.AddXY(hour, totalCalls);
}
}
}
}
Habe überlegt, das Ganze mal mit einem AsyncController auszuprobieren, aber letztlich will ich die Datenbankabfragen schon parallel laufen lassen, da die nacheinander wirklich lange brauchen (Bitte keine Vorschläge zur Optimierung des SQLs ;-))
Gruß
asymetrixs
IIS verarbeitet nur einen Request gleichzeitig
