Прием из запроса (.set, .append, .set-or-append, .set-or-replace)

Переключение служб с помощью раскрывающегося списка версий . Дополнительные сведения о навигации.
Область применения: ✅ Microsoft Fabric ✅ Azure Data Explorer

Эти команды выполняют запрос или команду управления и возвращают результаты запроса в таблицу. Разница между этими командами заключается в том, как они обрабатывают существующие или несуществующие таблицы и данные.

Чтобы отменить прием из команды запроса, см. раздел cancel operation.

Разрешения

Для выполнения различных действий в таблице требуются определенные разрешения:

• Чтобы добавить строки в существующую таблицу с помощью .append команды, требуется минимальное количество разрешений Ingestor таблицы.
• Чтобы создать новую таблицу с помощью различных .set команд, требуется минимальное количество разрешений пользователя базы данных.
• Чтобы заменить строки в существующей таблице с помощью .set-or-replace команды, требуется минимальное количество разрешений администратора таблиц.

Дополнительные сведения о разрешениях см. в разделе "Управление доступом на основе ролей Kusto".

Синтаксис

(.set | .append | .set-or-append | .set-or-replace) [async] tableName [with( propertyName= propertyValue [, ...]] )<|queryOrCommand

Дополнительные сведения о соглашениях синтаксиса.

Параметры

Советы по производительности

• distributed Задайте для свойства true значение, если объем данных, создаваемых запросом, велик, превышает один гигабайт (ГБ) и не требует сериализации. Затем несколько узлов могут создавать выходные данные параллельно. Не используйте этот флаг, если результаты запроса небольшие, так как может потребоваться создать множество небольших сегментов данных.
• Прием данных — это ресурсоемкая операция, которая может повлиять на одновременные действия в базе данных, включая выполнение запросов. Избегайте одновременного выполнения слишком большого количества команд приема.
• Ограничьте данные приема менее чем на одну ГБ на операцию приема. При необходимости используйте несколько команд приема.

Поддерживаемые свойства приема

Рекомендации по схеме

• .set-or-replaceсохраняет схему, если не задано extend_schemaодно из recreate_schema свойств приема или true приема.
• .set-or-append и .append команды сохраняют схему, если extend_schema для свойства приема не задано значение true.
• Сопоставление схемы результирующих наборов с целевой таблицей основано на типах столбцов. При этом имена столбцов не совпадают. Убедитесь, что столбцы схемы результатов запроса находятся в том же порядке, что и таблица, в противном случае данные будут приниматься в неправильные столбцы.

Ограничение символов

Команда завершается ошибкой, если запрос создает имя сущности с символом $ . Имена сущностей должны соответствовать правилам именования, поэтому $ символ должен быть удален для успешной команды приема.

Например, в следующем запросе search оператор создает столбец $table. Чтобы сохранить результаты запроса, используйте переименование проекта для переименования столбца.

.set Texas <| search State has 'Texas' | project-rename tableName=$table

Возвраты

Возвращает сведения об экстентах, созданных в результате выполнения команд .set или .append.

Примеры

Создание и обновление таблицы из источника запроса

Следующий запрос создает таблицу RecentErrors с той же схемой, что LogsTableи . Он обновляется RecentErrors со всеми журналами ошибок за LogsTable последний час.

.set RecentErrors <|
   LogsTable
   | where Level == "Error" and Timestamp > now() - time(1h)

Создание и обновление таблицы из источника запросов с помощью распределенного флага

В следующем примере создается новая таблица, вызываемая OldExtents в базе данных, асинхронно. Ожидается, что набор данных больше одного ГБ (более одного миллиона строк), поэтому используется распределенный флаг. Он обновляет OldExtentsExtentId записи из таблицы, созданной MyExtents более 30 дней назад.

.set async OldExtents with(distributed=true) <|
   MyExtents 
   | where CreatedOn < now() - time(30d)
   | project ExtentId

Добавление данных в таблицу

Следующий пример фильтрует ExtentId записи в MyExtents таблице, созданной более 30 дней назад, и добавляет записи в OldExtents таблицу с связанными тегами.

.append OldExtents with(tags='["TagA","TagB"]') <| 
   MyExtents 
   | where CreatedOn < now() - time(30d) 
   | project ExtentId

Создание или добавление таблицы с возможно существующими помеченными данными

Следующий пример добавляет или создает таблицу OldExtents асинхронно. Он фильтрует ExtentId записи в таблице, созданной MyExtents более 30 дней назад, и указывает теги, добавляемые в новые экстенты.ingest-by:myTag Параметр ingestIfNotExists гарантирует, что прием происходит только в том случае, если данные еще не существуют в таблице с указанным тегом.

.set-or-append async OldExtents with(tags='["ingest-by:myTag"]', ingestIfNotExists='["myTag"]') <|
   MyExtents
   | where CreatedOn < now() - time(30d)
   | project ExtentId

Создание таблицы или замена данных связанными данными

Следующий запрос заменяет данные в OldExtents таблице или создает таблицу, если она еще не существует, с ExtentId записями в MyExtents таблице, созданной более 30 дней назад. Пометьте новый экстент, если ingest-by:myTag данные еще не существуют в таблице с указанным тегом.

.set-or-replace async OldExtents with(tags='["ingest-by:myTag"]', ingestIfNotExists='["myTag"]') <| 
   MyExtents 
   | where CreatedOn < now() - time(30d) 
   | project ExtentId

Добавление данных с связанными данными

В следующем примере данные добавляются в OldExtents таблицу асинхронно с помощью ExtentId записей из таблицы, созданной MyExtents более 30 дней назад. Он задает определенное время создания для новых экстентов.

.append async OldExtents with(creationTime='2017-02-13T11:09:36.7992775Z') <| 
   MyExtents 
   | where CreatedOn < now() - time(30d) 
   | project ExtentId     

Пример выходных данных

Ниже приведен пример типа выходных данных, которые могут отображаться в запросах.

Связанный контент

• Форматы данных , поддерживаемые для загрузки
• Встроенное прием
• Прием из хранилища