0

У меня есть сценарий, в котором я отправляю два события событий в концентратор событий с разным идентификатором раздела/раздела.Использование нескольких разделов ключей в запросе Google Analytics для хранения данных в нескольких лазурных хранилищах Таблица

Теперь в моем аналитическом потоке я создал два входных псевдонима с одной строкой соединения (например, machine1input и machine2input) и два разных выходных псевдонима, но здесь каждый выходной псевдоним указывает на отдельное хранилище таблиц.

Теперь мои данные о событиях подобны этому.

{ 
    "MachineName": "M1", 
    "Date": "2016-05-26T13:35:30.1557995+05:30" 
} 
{ 
    "MachineName": "M2", 
    "Date": "2016-05-26T13:35:30.1557995+05:30" 
} 

и здесь я посылаю MachineName-M1 отделить Partition говорят 1 и MachineName-M2, чтобы отделить Partition сказать 2.

Теперь у меня есть две таблицы лазурь хранения говорят Machine1Record и Machine2Record. Теперь я хочу написать запрос в окне аналитических запросов потока таким образом, что запись Machine M1 должна получить в таблице Machine1Record, а запись Machine M2 должна автоматически получить в таблице Machine2Record как данные.

Я пробовал много запросов для достижения этого.

SELECT * INTO machine1output From machine1input PARTITION BY PartitionId where PartitionId = "1" 
SELECT * INTO machine2output From machine2input PARTITION BY PartitionId where PartitionId = "2" 
SELECT * INTO machine1output From machine1input where MachineName = "M1" 
SELECT * INTO machine2output From machine2input where MachineName = "M2" 

Но никто из них не работает. Пожалуйста, помогите нам в этом. Благодарю.

ответ

0

Если я правильно понимаю, вы используете единый центр событий, как два отдельных входа в поточную аналитику.

Вы можете использовать один вход из концентратора событий в свою работу по анализу потока. Затем вы можете создать два выхода из входного потока следующим образом.

SELECT * 
INTO machine1output 
FROM BothMachines 
PARTITION BY MachineName 
WHERE MachineName = "M1" 

SELECT * 
INTO machine2output 
FROM BothMachines 
PARTITION BY MachineName 
WHERE MachineName = "M2" 
+0

Привет, Спасибо за ответ. Но я уже это сделал, но он не работает, потому что, когда вы используете мой вышеопределяющий json в потоковом аналитическом окне запроса и просто нажмите кнопку тестирования, не даст вам никакого выхода. – JARVIS

+0

Если вы также видите эту ссылку, это означает, что для этого вам нужно создать два разных псевдонима ввода одного и того же концентратора событий, но он также не работает. Https: //social.msdn.microsoft.com/Forums/en-US/ aad1b6a9-15e4-4716-9c07-6705d0702c74/с использованием-многораздельные-ключей-в-аналитикой-запрос? Форум = AzureStreamAnalytics – JARVIS

0

Привет я этот вопрос решили единственную ошибку, что я делаю здесь проходит M1 и M2 в двойных кавычках в котором clause.I просто удалены двойные кавычки и используются одинарные кавычки, как это -

SELECT * INTO machine1output From machine1input where MachineName = 'M1' 
SELECT * INTO machine2output From machine1input where MachineName = 'M2' 

И теперь он отлично работает.