FTP-соединение с Airflow: укажите каталог по умолчанию

http://dev.mysql.com/doc/refman/5.5/en/insert.html

Операторы INSERT, использующие синтаксис VALUES, могут вставлять несколько строк. Чтобы сделать это, включите несколько списков значений столбцов, каждый из которых заключен в круглые скобки и разделен запятыми.

blockquote>

Пример:

INSERT INTO tbl_name (a,b,c) VALUES(1,2,3),(4,5,6),(7,8,9);

Вы можете использовать код для генерации вставить VALUES на основе вашего источника данных.

Ошибки: если в операторе INSERT (в том числе в любой из строк) есть ошибки, операция будет прервана.

Генерация запроса - это будет основано на вашем источнике данных, например, если вы получаете данные из ассоциативного массива в PHP, вы сделаете что-то вроде этого:

$sql = "INSERT INTO tbl_name (a, b, c) VALUES ";
foreach($dataset as $row)
{
    $sql .= "(" + $row['a'] + ", "  + $row['a'] + ", "  + $row['a'] + ")";
    // OR
    $sql .= "($row[a], $row[b], $row[c])";
}

Некоторые дополнительные ресурсы :

Оптимизация запросов MySQL - быстрые вставки с несколькими строками

Самый быстрый способ вставить записи 100K

1
задан dirtyw0lf 5 March 2019 в 15:26
поделиться

1 ответ

Вы можете ввести дополнительную информацию, такую ​​как путь, в дополнительное поле. Однако, используя или получая доступ к данным, например, FTPSensor требует от вас настройки (то есть подкласса) либо FTPSensor, и / или FTPHook в соответствии с вашими потребностями.

Существует пример использования дополнительных данных в хуке здесь , довольно просто создать собственный FTPHook / FTPSensor, который распознает ваши дополнительные данные. Например, существующий FTPHook уже использует некоторые из дополнительных данных (установка пассивного режима) - просто расширяйте или изменяйте, используя подклассы существующего FTPHook.

Было бы полезно посмотреть, как вы используете FTP-соединение в группе DAG.

0
ответ дан dorvak 5 March 2019 в 15:26
поделиться
Другие вопросы по тегам:

Похожие вопросы: