일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | |||
5 | 6 | 7 | 8 | 9 | 10 | 11 |
12 | 13 | 14 | 15 | 16 | 17 | 18 |
19 | 20 | 21 | 22 | 23 | 24 | 25 |
26 | 27 | 28 | 29 | 30 | 31 |
- Bolton
- wuhan
- 중국외교부
- sharonchoi
- 봉준호감독통역사
- 미중
- 진짜영웅
- 코로나19
- 우한코로나바이러스
- 전염병
- 우한
- cnn
- 우한 코로나
- 창궐
- 정은경 본부장님
- 코로나바이러스
- 최성재
- 조현병
- 웨일즈
- 치앙마이
- everybody wants you
- 어서와한국은처음이지
- 봉준호감독통역
- 필리핀사망
- red hearse
- 신종코로나
- parasite
- 코로나
- 확진자수
- 우한코로나
- Today
- Total
오지's blog
connection_args = {"user":SNOWFLAKE_IMED_DB_USER ,"private_key":pkb ,"account":SNOWFLAKE_IMED_DB_HOST ,"warehouse":'GCIMED_WH' ,"database":'GCIMED_DB' ,"schema":'DM'}with snow.connect(**connection_args) as conn:
import datetimefrom pytz import UTCoriginal_time = datetime.datetime(1970, 1, 1, 0, 0, 0, tzinfo=UTC).timestamp()now = datetime.datetime.now().timestamp()
JDBC;DRIVER={net.snowflake.client.jdbc.SnowflakeDriver};URL={jdbc:snowflake://xxx.ap-northeast-2.aws.snowflakecomputing.com/?user=xx&password=xxx&warehouse=xxx&db=xx&schema=DM&private_key_file=/app/mstr/MicroStrategy/keys/xx.p8&private_key_pwd=xxx};CLIENT_PREFETCH_THREADS=10;fetchsize=160; 아래로 변경 JDBC;DRIVER={net.snowflake.client.jdbc.SnowflakeDriver};URL={jdbc:snowflake://xxx.ap-northeast-2.aws..
ip를 추가해도 접속이 안되서 알아보니 vpc의 라우팅테이블에도 추가해야 한다.
https://sftp_multiple_files_download_operator.py/ import os from airflow.exceptions import AirflowException from airflow.models import BaseOperator # from airflow.contrib.hooks import SSHHook from airflow.providers.ssh.hooks.ssh import SSHHook from typing import Any class SFTPMultipleFilesDownloadOperator(BaseOperator): template_fields = ('local_directory', 'remote_filename_pattern', 'remote_hos..