Streaminsight и долгосрочные запросы -- c# поле с участием .net поле с участием complex-event-processing поле с участием streaminsight пол Связанный проблема

StreamInsight and long running queries


0
vote

проблема

русский

У меня есть приложение, построенное на вершине Streaminsight 1.2, который имеет несколько постоянных запросов, выполняющих некоторые расчеты в операторах определенных пользователей. Изредка один из расчетов примет относительно долгое время для завершения (несколько секунд), и я вижу, что он блокирует другие запросы от выполнения. Я не очень знаком с тем, как Streaminsight работает так от этого, я предпочитаю, что все запросы бегают в одном потоке. Есть ли способ проходить через параллель?

Помимо каким-то образом положить запросы на отдельные нити, есть ли другие вещи, которые я мог сделать, чтобы предотвратить блокировку одного спорадически долгого ходатайства от блокировки других запросов?

Английский оригинал

I have an application built on top of StreamInsight 1.2 that has several standing queries running some calculations in User Defined Operators. Occasionally one of the calculations will take a relatively long time to complete (a few seconds), and I'm seeing that it blocks the other queries from executing. I'm not very familiar with how StreamInsight works so from this I'm speculating that all queries are run on a single thread. Is there some way to have the queries run in parallel?

Aside from somehow putting the queries on separate threads, are there any other things I could do to prevent one sporadically long running query from blocking other queries?

</div
           

Список ответов

1
 
vote
vote
Лучший ответ
 

Если расчет иногда потребуется несколько секунд, и это природа этого и , вы используете стандартное издание, лучшее, что вы можете сделать, это не блокировать нить, когда вычисление место. StreamInsight не имеет ничего встроенного для этого ... это your ответственность. От перспективы Streaminsight ваш UDO занимает некоторое время. Это не знает, почему это так. И если нить заблокирована, она не может запускать ничего, пока ваш UDO не возвращается. Таким образом, я бы а) проверил, что вы используете стандартное издание, а затем B), если вы находитесь, измените UDO так, чтобы он неблокировал / async.

 

If the calculation will occasionally take a few seconds and that's the nature of it and you are running Standard Edition, the best thing that you can do is to not block the thread while the calculation is taking place. StreamInsight doesn't have anything built-in for this ... it's your responsibility. From StreamInsight's perspective, your UDO is taking some time. It doesn't know why that is. And if the thread is blocked, it can't run anything else until your UDO returns. So I would a) validate that you are running standard edition and then b) if you are, change the UDO so that it's non-blocking/async.

</div
 
 
     
     
1
 
vote

Какое издание Streaminsight вы используете? Стандартное издание запускает планировщик на одном ядре, а Premium использует все доступные ядра. Что касается задержки, если все ваши запросы зависят от временной шкалы, которая повесила - через присоединение, Союз и т. Д. - Тогда это то, что заставляет его повесить. События не «выпущены» от долгосрочного Uдо, чтобы накормить другие потоки. Если это так, нет ничего, что вы можете сделать, если вы не можете реструктурировать запросы каким-то образом. Я также начал смотреть, почему «иногда» UDO займет несколько секунд. Это приводит меня к тому, что есть что-то асис с Удо, но тогда, не зная деталей того, что он делает, я не могу сказать наверняка.

 

Which edition of StreamInsight are you using? Standard Edition runs the scheduler on a single core while Premium uses all available cores. As for the delay, if all of your queries are dependent on the timeline that's hung up - via join, union, etc. - then that's what's causing it to hang up. Events aren't "released" from the long-running UDO to feed the other streams. If this is the case, there isn't anything that you can do unless you can restructure the queries in some way. I'd also start looking into why "occasionally" the UDO will take a few seconds. This leads me to think that there's something amiss with the UDO but then, not knowing the details of what it's doing, I can't say for sure.

</div
 
 
   
   

Связанный проблема

12  Сырые запросы SQL и основной базы  ( Raw sql queries and entity framework core ) 
Я переносим свое приложение в Core Ass.net MVC Core и Framework Framework, и я нашел проблему. У меня есть RAW SQL-запрос к сущности, как это <код> var rawS...

0  C # сделать в то время как Unassigned локальной проблемы переменной  ( C sharp do while unassigned local variable problem ) 
<Р> Я после C # курса и пытаюсь обновить мой метод ввода пользователя, чтобы проверить, если введенная входную консоль целое. Я написал сам в то время как сдел...

0  Должен ли я использовать ExecuteNonQuery для этой команды резервного копирования БД  ( Should i use executenonquery for this db backup command ) 
<Р> У меня есть метод, который позволяет мне пнуть резервную копию базы данных. То, что я интересно, если я должен использовать ExecuteNonQuery () в этом конте...

1  Xero C # «Текущий токенопозиторий не имеет токена текущего запроса»  ( Xero c sharp the current tokenrepository doesnt have a current request token ) 
удалось подключиться к Xero API и получить токен запроса. Однако после перезапуска проекта (для отладки) он в основном дает следующую ошибку при проложении то...

-4  Будет вернуться внутрь памяти утечки для петли?  ( Will a return inside of a for loop leak memory ) 
в основном все, что мне нужно знать, является ли возвращение внутри цикла для цикла в C #. <код> for (int i = 0; i <= 20; i++ ) { if(i == 10) re...

2  SMTPClient отправляет RAW HTML  ( Smtpclient sending raw html ) 
Может ли кто-нибудь сказать мне, почему следующий код отправляет электронные письма в Raw HTML? Как в, электронная почта выглядит когда вы просматриваете исто...

0  Linq 2 SQL Использование содержит [дубликат]  ( Linq 2 sql using contains ) 
<в сторону CLASS = "S-NEWACTS S-WELTIVE__info JS-Post-New Imide MB16« Роль = «Статус»> Этот вопрос уже есть ответы здесь : ...

5  Можем ли мы использовать ответ .Flush () вместо ответа. Денды ()  ( Can we use response flush instead of response end ) 
<Код> Response.End() генерирует <код> ThreadAbortException . Использование <код> HttpContext.Current.ApplicationInstance.CompleteRequest вместо этого не р...

0  HAL, чтобы десерифицировать ответ JSON, если количество полей от ответа не известно?  ( Haw to deserialize json response if the number of fields from the response not k ) 
С тех пор, как я не сейчас, сколько полей ответа JSON не смогу ли у вас сложный код, чтобы соответствовать объекту JSON. Что такое лучшая практика для десериа...

8  Требуется 407 аутентификация - не отправлено проблем  ( 407 authentication required no challenge sent ) 
<Сильное> Обновление: Если вы только что прибыли на этот вопрос, генеральный сигнал заключается в том, что я пытаюсь сделать httpwebrequest через прокси, и ...

2  Обращайтесь с событиями для динамического (время выполнения) - vb.net  ( Handle events for dynamic run time controls vb net ) 
У меня есть элемент управления WebBrowser, который создается и добавляется в форму во время выполнения. Как подключить этот элемент управления подпрограммой...

1  ASP.NET Печать PDF непосредственно к принтеру с настройками  ( Asp net print pdf directly to printer with preferences ) 
Я работаю над проектом, который требует от нас отправлять PDFS на печатную прессу. Ранее мы сделали это с помощью настольного приложения и Acrobat, но я хотел...

4  Как написать на пользовательский журнал событий?  ( How to write to a custom event log ) 
Я пытаюсь получить мою службу .NET Windows вправо на пользовательский журнал событий. Я использую <код> EventLogInstaller , чтобы создать журнал событий и ист...

1  WIX Набор инструментов Build не удается после обновления от .NET 4.0 до 4.6.1: не может загрузить MSBuild Wrapper?  ( Wix toolset build fails after upgrading from net 4 0 to 4 6 1 cannot load msbu ) 
Так после обновления всего проекта до 4.6.1 Я получаю эту ошибку, выброшенную нагревом, когда я его создаю: <код> Failed to load MSBuild wrapper object: Cou...

1  Служба окна в C # (ServiceProcessInsaller) - Ошибка 5: Доступ запрещен  ( Window service in c sharp serviceprocessinsaller error 5 access is denied ) 
Я использую Visual Studio 2008 и .NETFramework 3.5. Я разработал одно приложение Windows Service в C # с помощью файловой системы. Основная цель этого проекта...

Связанный проблема

12  Сырые запросы SQL и основной базы 
0  C # сделать в то время как Unassigned локальной проблемы переменной 
0  Должен ли я использовать ExecuteNonQuery для этой команды резервного копирования БД 
1  Xero C # «Текущий токенопозиторий не имеет токена текущего запроса» 
-4  Будет вернуться внутрь памяти утечки для петли? 
2  SMTPClient отправляет RAW HTML 
0  Linq 2 SQL Использование содержит [дубликат] 
5  Можем ли мы использовать ответ .Flush () вместо ответа. Денды () 
0  HAL, чтобы десерифицировать ответ JSON, если количество полей от ответа не известно? 
8  Требуется 407 аутентификация - не отправлено проблем 
2  Обращайтесь с событиями для динамического (время выполнения) - vb.net 
1  ASP.NET Печать PDF непосредственно к принтеру с настройками 
4  Как написать на пользовательский журнал событий? 
1  WIX Набор инструментов Build не удается после обновления от .NET 4.0 до 4.6.1: не может загрузить MSBuild Wrapper? 
1  Служба окна в C # (ServiceProcessInsaller) - Ошибка 5: Доступ запрещен