오지's blog

지인이 링크를 보내주어 이끌림싸이트에서 라면을 주문했다. https://www.eggeullim.com/ 이끌림이끌림www.eggeullim.com 근데 검색해보니 사기일 가능성이 높아 보이나 비회원주문으로 입력한 정보들이 기억이 나지 않아 주문취소를 못하고 있다.전화도 계속 통화중이다. ㄷㄷ https://m.ppomppu.co.kr/new/bbs_view.php?id=freeboard&no=8836216&page=1 라면 할인이벤트 행사하는 사이트인데 감정좀 해주세요.뽐뿌에 있을것 같은데 없어서, 라면 가격은 저렴한것 같은데 처음보는 쇼핑몰이라 그런지 인기가 없나보네m.ppomppu.co.kr  부디 사기가 아니고 정상 배송이 왓으면 한다. 기억에 까먹지 않도록 하기 위해 블로그에 적는다.  사기일 ..

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..

SELECT REG_DATE FROM ( SELECT DISTINCT(REPLACE(SUBSTR(CNSL_REG_TME, 1, 10), '-', '')) AS REG_DATE FROM GCWB_WDB.ODS.O_CS_CNSL_HST ) ORDER BY REG_DATE DESC; 하나씩 풀어간다

result = engine.execute(f"SELECT TABLE_NAME FROM information_schema.TABLES WHERE ENGINE LIKE '%InnoDB%' AND TABLE_TYPE='BASE TABLE';").fetchone() ValueError: unsupported format character 'I' (0x49) at index 69 에러 발생 % 대신 %%으로 수정하여 해결 result = engine.execute(f"SELECT TABLE_NAME FROM information_schema.TABLES WHERE ENGINE LIKE '%%InnoDB%%' AND TABLE_TYPE='BASE TABLE';").fetchone()

df = pd.read_sql_query(sql = sql, con = mysql_conn) AttributeError: 'OptionEngine' object has no attribute 'execute' 다음과 같이 변경 필요 df = pd.read_sql_query(sql = text(sql), con = mysql_conn.connect()) reference. https://levelup.gitconnected.com/how-to-fix-attributeerror-optionengine-object-has-no-attribute-execute-in-pandas-eb635fbb89e4 How to Fix AttributeError: ‘OptionEngine’ object has no attrib..

sf_hook = SnowflakeHook(snowflake_conn_id="SNOWFLAKE_CONN_ID") sql = f"SELECT DISTINCT(REPLACE(SUBSTR({date_column_name}, 1, 10),'-', '')) FROM {table_name} WHERE SUBSTR({date_column_name}, 1, 10)='{yesterday.strftime(date_string)}';" conn = sf_hook.get_conn() cursor = conn.cursor() cursor.execute(sql) result = cursor.fetchone() 참고 https://stackoverflow.com/questions/53565834/fetch-results-from-..