Описание тега snowflake-stream
Для сообщений, относящихся к потокам Snowflake:
https://docs.snowflake.com/en/sql-reference/sql/create-stream.html
2
ответа
Планирование задач на основе событий Snowflake вместо планирования задач на основе времени
Мне нужны примеры планирования задач на основе событий Snowflake вместо планирования задач на основе времени. Я не смог найти эти примеры в документе со снежинками. заранее спасибо
21 апр '20 в 07:13
1
ответ
CDC с безопасными представлениями Snowflake
Есть ли способ включить потоки в представлениях, чтобы я мог отслеживать, что изменилось. Пример сценария: обработка данных PII с помощью защищенных представлений путем создания двух представлений для каждой таблицы, например, таблица ORDERS содержи…
06 апр '20 в 02:28
0
ответов
В задаче Snowflake у нас есть что-то вроде дочерней задачи, которая будет ждать, пока не встретятся зависимости, кроме условия родительской задачи
У меня 4 потока. A_STREAM, B_STREAM, C_STREAM, D_ STREAM У меня есть цепочка задач, в которой A_TASK является родительской и имеет 3 дочерних задачи (B_TASK, C_TASK, D_TASK). CREATE TASK A_TASK WAREHOUSE = XYZ SECHDULE = '15 MINUTE' WHEN SYSTEM$STRE…
15 авг '20 в 19:49
1
ответ
Привязка динамического значения Snowflake и постоянное значение
Мне нужно передать динамическое значение в качестве имени столбца в мою таблицу из цикла и постоянное значение. Мой фрагмент кода выглядит примерно так:While(res.next()){var columnname= res.getColumnValue(1);var stmt=insert into table1(column1,colum…
07 апр '20 в 17:52
0
ответов
Альтернатива потоковой передаче на общем столе
Я создаю непрерывный конвейер данных, используя задачи и потоки. Он хорошо работает для большинства моих решений, за исключением случаев, когда мои исходные данные представляют собой базу данных из общего ресурса Snowflake. Хотя я не могу ничего явн…
22 апр '20 в 00:31
0
ответов
проблема с функцией извлечения в SF
SELECT CAST(извлечение (день ОТ (BV_REPAIR_ORDER_RECEIPT.REPAIR_ORDER_RECEIPT_DTM-BV_REPAIR_ORDER_LINE.ROL_ACTUAL_SHIPMENT_DTM день (4) до секунды) * 86400) Ошибка - ошибка компиляции SQL: строка синтаксической ошибки 2 в позиции 117 неожиданный "де…
27 апр '20 в 09:58
1
ответ
Как создать вид редактирования в снежинке?
Я пытаюсь преобразовать ddl для представления оракула в представление снежинки. Но в Oracle ddl созданное представление имеет тип FORCE EDITIONING. Но эти ключевые слова не поддерживаются снежинкой. Может ли кто-нибудь поделиться идеями по воспроизв…
07 май '20 в 14:28
2
ответа
Вставить в несколько таблиц с помощью потока и задач
Согласно официальной документации, это изображает, как будто мы можем вставить в несколько таблиц из задачи. Что звучит неточно, поскольку После использования смещения потока сбрасываются. Из задачи можно выполнить только один оператор SQL. я что-то…
05 июн '20 в 19:16
2
ответа
Snowflake: команда копирования не генерирует постоянный размер для нескольких файлов при выгрузке
скопировать в @elasticsearch/product/s3file из (выберите object_construct(*) из mytable) file_format = (type = json, COMPRESSION=NONE), overwrite=TRUE, single = False, max_file_size=5368709120; в таблице 2 ГБ данных. Я хочу разделить их на файлы раз…
13 авг '20 в 14:57
3
ответа
Snowflake с использованием потоков для отслеживания обновлений / удалений в таблице
Мне сложно понять, как работают Streams с точки зрения отслеживания изменений. Я хотел бы создать таблицу истории, в которой отслеживаются всеUPDATE а также DELETE к столу, но я обнаружил, что не понимаю, как это работает. Если у меня есть стол Tabl…
13 авг '20 в 17:06
1
ответ
Как загрузить 533 столбца данных в таблицу снежинок?
У нас есть таблица с 533 столбцами с множеством столбцов LOB, которые нужно переместить в снежинку. Поскольку у нашей системы преобразования исходного кода возникла проблема с управлением 533 столбцами за одно задание. Мы разделили столбцы на 2 зада…
21 май '20 в 16:17
1
ответ
SnowSql нет ответа
Я использую SnowSql 1.2.5, и я не получаю ни ответа, ни ошибки, ничего от него. Неважно, какую команду я набираю, даже если набрать просто "SnowSql.exe" и нажать "Подтвердить", я не получу ответа. Это происходит на определенной машине, на других с т…
09 июн '20 в 12:07
1
ответ
Snowflake Java Script User Defined Table Function
How do I return a table with multiple columns from Snowflake Javascript UDF / UDTF?
30 июн '20 в 21:45
0
ответов
Как организовать дорожку для сцены стола в Снежинке?
Как организовать этап внутреннего стола в Snowflake? Если мы создаем таблицу, мы можем поместить файл в соответствующую стадию по умолчанию, используя команду ниже. поместить файл://<>/ имя_файла @% <<имя_таблицы>> Но в соответствии с некоторой доку…
09 июл '20 в 22:22
2
ответа
Snowflake Stream стал пустым, даже если мы потребляем всего несколько записей из данных Stream
Я вижу, что набор потоковых данных стал пустым, даже если я использую только одну запись из набора потоковых данных. Я не думаю, что это правильно. Вот шаги, которые я сделал. - Создайте таблицу для хранения имен и сборов, выплачиваемых участниками …
21 июл '20 в 23:13
0
ответов
Как передать данные из снежинки в кафку
Я пытаюсь построить конвейер данных от снежинки до Кафки. Предпочтительно я хочу использовать AWS MSK. Я мог найти несколько документов для потоковой передачи данных в Snowflake из Kafka, но я ищу другой способ.
28 авг '20 в 23:44
1
ответ
Проблемы Snowflake Data Pipeline - в частности, проблема с потоком
Задний план Я реализовал конвейер данных снежинки (файл журнала s3> SNS > труба> таблица этапов> поток> задача> сохраненный процесс /UDF > итоговая таблица) в нашей производственной базе данных снежинок. В то время как в нашей базе данных разработчи…
20 мар '20 в 20:54
1
ответ
Коннектор SnowFlake-Kafka -> Посадочный стол -> Целевой стол. Как очистить посадочный стол
Я изучаю данные из Kafka -> SnowFlake/Kafka connector -> SnowFlake. К сожалению, коннектор, похоже, использует только два столбца (и помещает всю полезную нагрузку JSON в один столбец). Поэтому я создал поток / задачу для периодического копирования …
12 май '20 в 08:31
0
ответов
Как построить запрос Snowflake для получения этих результатов
Приведенная ниже таблица (TMP_RN_TC) в запросе - это временная таблица, которая будет использоваться для загрузки данных в окончательную таблицу. Эта таблица должна получать данные из stage-table, а вывод данных временной таблицы должен храниться в …
17 июл '20 в 13:27
1
ответ
Как передать диапазон дат в предложении where в снежинке при написании запроса
Как передать диапазон дат в предложении where в снежинке при написании запроса и избежать дублирования также при следующем запуске. У меня есть запрос ниже, и мне нужно получать данные за 15 дней каждый день до предыдущего дня. Данные будут переданы…
17 июл '20 в 18:28