2021-10-01から1ヶ月間の記事一覧
■ はじめに https://dk521123.hatenablog.com/entry/2020/01/29/224525 で発生したトラブルについて、まとめる。 目次 【1】UpdateConnection を実行したら AccessDeniedExceptionが発生 【1】UpdateConnection を実行したら AccessDeniedExceptionが発生 …
■ はじめに Snowflake の セミナーを受けていて、 date_trunc() がでてきて、今後も使えそうだったので SQLの日付・日時に関する操作する関数を 徐々にメモっていく。 目次 【1】DATE_TRUNC関数 【1】DATE_TRUNC関数 * 指定した単位(「hour」「month」な…
■ はじめに https://dk521123.hatenablog.com/entry/2024/02/10/231900 の続き。 AWS CloudFormation (CFn) を触ったのでメモ。 目次 【1】手順 1)新規作成 2)設定変更 【2】サンプル 例1:1 VPC 1 Subnet作成 例2:EC2インスタンス構築 (イメージ) …
■ はじめに https://dk521123.hatenablog.com/entry/2021/10/23/025230 https://dk521123.hatenablog.com/entry/2022/01/10/155206 の続き。 上記の記事で、環境設定で「pulumi version」や Hello World で「pulumi new」などで扱っていたが、 Pulumi には、…
■ はじめに Pulumi について、メモ。 目次 【1】Pulumi 0)公式サイト 1)対応言語 2)対応プロバイダ 3)料金 【2】pulumi の構成 【3】用語整理 1)Stack (スタック) 2)State 【1】Pulumi * Pulumi (プルミ) * Infrastructure As Code(IaC= イ…
■ はじめに Infrastructure As Code(IaC)の Pulumi (プルミ) っていうのがらしく 学習用に、Windowsでインストールできないかなって調べてみたら 以下のように「Chocolatey ... choco install pulumi」ってあって なんだこれってので調べてみた。 https://…
■ はじめに https://dk521123.hatenablog.com/entry/2021/10/10/000000 でリトライ(Re-run)を扱ったが、その調査の過程で、 以下のサイト https://blog.imind.jp/entry/2019/02/22/000049 などで コマンド(CLI; Command Line Interface)からでも、 タス…
■ はじめに Amazon WorkSpaces(アマゾン ワークスペース) ってのを 使うことになりそうなので、予習しておく。 目次 【1】Amazon WorkSpaces 【2】利点 【3】料金 【4】環境 1)OS 2)オプション 3)接続プロトコル 4)クライアントの対応OS 【5…
■ はじめに https://dk521123.hatenablog.com/entry/2021/10/10/000000 https://dk521123.hatenablog.com/entry/2021/10/12/000000 の続き。 今回は、同実行数などの並列・マルチスレッド関連の設定について扱う 目次 【1】airflow.cfgでの制御 - Airflow全…
■ はじめに 色々と Airflow を触っていると 設定値を保持する仕組み・機構が揃っているので、 その内の Connection について扱う Apache Airflow ~ Variable ~ https://dk521123.hatenablog.com/entry/2023/12/17/000000 目次 【0】コネクションの保持 - …
■ はじめに https://dk521123.hatenablog.com/entry/2021/10/13/092235 の続き。 どうも Slackに対して、Tokenを使ってメッセージを表示させるより Incoming Webhooks 経由で主流のようなので調べてみた。 調査してみて感じたのは、結構、古い内容が多々ある…
■ はじめに https://dk521123.hatenablog.com/entry/2021/06/03/175213 の続きで、Amazon Simple Notification Service(SNS)について。 https://dk521123.hatenablog.com/entry/2021/10/06/141323 で、Airflow において、 Amazon SNS経由でEmailを受信する…
■ はじめに https://dk521123.hatenablog.com/entry/2021/10/06/141323 で、Airflow で Slack へ通知する際に、 Access Token(アクセストークン)が必要だったのでメモる。 簡単かなーっと思ったら意外と調べたりするのに時間が掛かった、、、 目次 【1】…
■ はじめに Apache Airflow の タイムアウト について扱う。 目次 【1】DAGのタイムアウト関連のプロパティ 1)dagrun_timeout 2)dag_file_processor_timeout 3)dagbag_import_timeout 4)使用イメージ 【2】タスクのタイムアウト関連のプロパティ …
■ はじめに https://dk521123.hatenablog.com/entry/2021/07/18/004531 で、ローカル上に Airflowの環境を構築したが、 いつの間にか環境がぶっつぶれた。 どうせなら、Dockerでやってみようと思ったので、メモ。 目次 【1】前提条件 【2】構築環境例 【3…
■ はじめに Apache Airflow の リトライ について扱う。 目次 【1】手動でリトライ - 再実行 【2】airflow.cfgでの制御 - Airflow全体の設定 1)default_task_retries 2)max_db_retries 【3】タスクのリトライ関連のプロパティ 1)retries 2)retry_…
■ はじめに https://dk521123.hatenablog.com/entry/2021/10/06/141323 の続き。 通知に関するサンプルをまとめておく。 目次 例1:SlackAPIPostOperatorを使ってSlackへ通知 1)前提条件 2)サンプル 例2:SlackWebhookOperatorを使ってSlackへ通知 1…
■ はじめに https://dk521123.hatenablog.com/entry/2021/09/29/131101 で、MWAA(Amazon Managed Workflow for Apache Airflow)を 使っていて、出くわした問題について、徐々にでは、 その解決方法などのトラブルシュートをメモっておく。 今回以外のトラ…
■ はじめに https://dk521123.hatenablog.com/entry/2021/10/05/105550 のコードを AWS Lambda (ラムダ)で実行する必要ができたのだが よくよく考えると Lambda は、Javaでしか組んだことがなく、 Python は初めてだったので、メモっておく。 後、大分、前に…
■ はじめに Apache Airflow で処理の失敗時やワークフロー成功時に 以下のサービスへ通知する方法を調べたので、メモっておく。 ~~~~~~~~~~ 【1】Slack 【2】Email / AWS SES 【3】AWS SNS 【4】Microsoft Teams ~~~~~~~~~~ 目次 【0】全般的な注意点 …
■ はじめに https://dk521123.hatenablog.com/entry/2020/03/12/220717 の続き。 Secrets Manager に含まれている情報を、 boto3 でアクセスして、ごにょごにょする必要ができたので 調べて、メモを残しておく。 目次 【1】API仕様 1)get_secret_value() …
■ はじめに https://dk521123.hatenablog.com/entry/2021/09/29/131101 の続き。 今回は、以下のサイトで 使用されている S3 Sensor について調べてみた https://amazon-mwaa-for-analytics.workshop.aws/en/workshop-2.0.2/m1-processing/s3.html 目次 【1…
■ はじめに https://dk521123.hatenablog.com/entry/2021/07/18/004531 で発生したトラブルを纏めておく。 目次 【1】Dockerによる環境設定でdocker-compose up後にエラー表示 【2】エラー「ModuleNotFoundError: No module named 'airflow.providers'」が…
■ はじめに 文字列からbool に変換する際に 【1】の「意図した動作にならなかった例」のように 実装したが、うまくいかなかったので、メモっておく。 目次 【1】文字列 => bool に変換する際の注意点 【2】文字列 => bool に変換 1)補足:distutilsパッ…
■ はじめに https://dk521123.hatenablog.com/entry/2021/10/05/105550 で、json化するのに普段は、json.loads()を使っていたのだが astモジュールってのがあるのは知らなかった。 目次 【1】astモジュール 【2】literal_eval() 1)json.loads() との違い…