goodbyegangster

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import csv, glob, MeCab

result_file = "XXXXXXXX"
dic_file = "XXXXXXXX"
shikiho_file = "XXXXXXXX"

headmsg = ["code","comment","value"]

goodbyegangster

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import os, csv, threading, re
from time import sleep
from selenium import webdriver
from pyquery import PyQuery
from logging import getLogger, FileHandler, Formatter, DEBUG

logger = getLogger(__name__)

goodbyegangster

"""
Google Cloud Storage から Bucket 情報の一覧を取得するスクリプト
- Python 3.9.6
- google-cloud-storage==1.42.3
"""
import csv
from google.cloud import storage


def run():

goodbyegangster

"""
FastAPIの基本的記法
- Python 3.9.7
- FastAPI 0.70.0
- uvicorn 0.15.0
"""
import uvicorn
from typing import Optional
from fastapi import FastAPI, Query, HTTPException
from pydantic import Field, BaseModel

goodbyegangster

from datetime import datetime, timedelta
from textwrap import dedent

from airflow import DAG
from airflow.operators.bash import BashOperator
from airflow.operators.python import PythonOperator
from airflow.decorators import task

# define default arguments for operators.
default_args = {

goodbyegangster

from datetime import datetime, timedelta

from airflow import DAG
from airflow.operators.empty import EmptyOperator
from airflow.decorators import task
from airflow.decorators.branch_python import branch_task


@task(task_id='beginning')
def beginning() -> int:

goodbyegangster

from datetime import datetime, timedelta

from airflow import DAG
from airflow.operators.python import ShortCircuitOperator
from airflow.operators.empty import EmptyOperator


def is_even_number() -> bool:
    import random
    number = random.randint(1, 10)

goodbyegangster

from datetime import datetime, timedelta

from airflow import DAG
from airflow.operators.trigger_dagrun import TriggerDagRunOperator

with DAG(
    dag_id='trigger_run_dag',
    description='A Sample TriggerDagRunOperator DAG',
    schedule_interval=timedelta(days=1),
    start_date=datetime(2022, 6, 1),

goodbyegangster

from datetime import datetime

from airflow import DAG
from airflow.decorators import task


@task(task_id='pring_message')
def print_message(dag_run=None) -> None:
    print(f'received message: {dag_run.conf["message"]}.')

goodbyegangster

from datetime import datetime, timedelta, timezone

from airflow import DAG
from airflow.operators.empty import EmptyOperator
from airflow.sensors.external_task import (
    ExternalTaskMarker,
    ExternalTaskSensor,
)

JST = timezone(timedelta(hours=+9), 'JST')