DM
Size: a a a
2020 September 24
ВТ
Спасибо за инфу)
VS
А диск на сколько?
Диски по 100гб, просто потому, что с логами до сих пор нормально проблему не могу решить 😔
VN
Диски по 100гб, просто потому, что с логами до сих пор нормально проблему не могу решить 😔
Понял, благодарю
2020 September 25
ET
не у кого не было такого что даг по расписанию запускает только одну таску?
VS
localexecuter на sqlite?
А
сделав class PgOperator(BaseOperator)
self.sql = sql
self.postgres_conn_id = postgres_conn_id
пишу task .py
postgres_zapros = PgOperator(
task_id='analytics',
postgres_conn_id='postgres',
sql = 'select * from {{ params.table_name }}',
а где прописывать параметры
params.table_name
имя таблицы , как передать сюда
self.sql = sql
self.postgres_conn_id = postgres_conn_id
пишу task .py
postgres_zapros = PgOperator(
task_id='analytics',
postgres_conn_id='postgres',
sql = 'select * from {{ params.table_name }}',
а где прописывать параметры
params.table_name
имя таблицы , как передать сюда
VS
Может ещё быть sequentialexecutor :)
он вроде на sqlite
ME
он вроде на sqlite
Они же независимые, можно на MySQL, например
VS
Они же независимые, можно на MySQL, например