syossan27

codes = Set[]
while codes.size != num
  code = (0...6).map { '1234567890qwertyuiopasdfghjklzxcvbnmQWERTYUIOPASDFGHJKLZXCVBNM'.chars[rand(62)] }.join
  next if codes.add?(code).nil?
end

syossan27

func deleteAllRows(ctx context.Context, db *spanner.Client, tableName string) {
  stmt := spanner.Statement{
		SQL: "DELETE FROM `" + tableName + "` WHERE true",
	}
  
	_, err := db.PartitionedUpdate(ctx, stmt)
	if err != nil {
		panic(err)
	}
	return

syossan27

func ReverseBit(num uint64) uint64 {
	return bits.Reverse64(num)
}

syossan27

func deleteAllRowsByMultiPK(ctx context.Context, db *spanner.Client, tableName string, primaryFirstKeyName string, primarySecondKeyName string) {
	var primaryKeys []*spanner.Mutation

	stmt := spanner.Statement{SQL: "SELECT `" + primaryFirstKeyName + "`, `" + primarySecondKeyName + "` FROM `" + tableName + "`"}
	iter := db.Single().Query(ctx, stmt)
	defer iter.Stop()
	for {
		row, err := iter.Next()
		if err == iterator.Done {
			break

syossan27

func deleteAllRows(ctx context.Context, db *spanner.Client, tableName string, primaryKeyName string) {
	var primaryKeys []string

	stmt := spanner.Statement{SQL: `SELECT ` + primaryKeyName + ` FROM ` + tableName}
	iter := db.Single().Query(ctx, stmt)
	defer iter.Stop()
	for {
		row, err := iter.Next()
		if err == iterator.Done {
			break

syossan27

import requests
import re
import json

from airflow import DAG
from airflow.contrib.sensors.gcs_sensor import GoogleCloudStoragePrefixSensor
from airflow.contrib.operators.gcs_to_bq import GoogleCloudStorageToBigQueryOperator
from airflow.exceptions import AirflowException
from airflow.hooks.http_hook import HttpHook
from airflow.operators.http_operator import SimpleHttpOperator

syossan27

import requests

from airflow import DAG
from airflow.contrib.sensors.gcs_sensor import GoogleCloudStoragePrefixSensor
from airflow.contrib.operators.gcs_to_bq import GoogleCloudStorageToBigQueryOperator
from airflow.exceptions import AirflowException
from airflow.hooks.http_hook import HttpHook
from airflow.operators.http_operator import SimpleHttpOperator
from airflow.operators.python_operator import PythonOperator
from airflow.utils.dates import days_ago

syossan27

import requests

from airflow import DAG
from airflow.contrib.sensors.gcs_sensor import GoogleCloudStoragePrefixSensor
from airflow.contrib.operators.gcs_to_bq import GoogleCloudStorageToBigQueryOperator
from airflow.exceptions import AirflowException
from airflow.hooks.http_hook import HttpHook
from airflow.operators.http_operator import SimpleHttpOperator
from airflow.utils.dates import days_ago
from datetime import timedelta, datetime

syossan27

import requests

from airflow import DAG
from airflow.contrib.sensors.gcs_sensor import GoogleCloudStoragePrefixSensor
from airflow.exceptions import AirflowException
from airflow.hooks.http_hook import HttpHook
from airflow.operators.http_operator import SimpleHttpOperator
from airflow.utils.dates import days_ago
from datetime import timedelta, datetime

syossan27

from airflow import DAG
from airflow.contrib.sensors.gcs_sensor import GoogleCloudStoragePrefixSensor
from airflow.utils.dates import days_ago
from datetime import timedelta, datetime

dag = DAG(
    'inference_pipeline', # DAGの名称
    default_args={
        'start_date': days_ago(1), # DAGがスケジューリングされる日付を指定
        'retries': 1,              # タスク失敗時のリトライ回数の指定