syossan27’s gists

syossan27 / list-requested-review-pr.yaml

Last active August 7, 2021 12:07

	name: "Notice of need review PR"
	on:
	schedule:
	- cron: "0 10,17 * * 1-5" # 月〜金の10時, 17時に実行

	jobs:
	notice:
	runs-on: ubuntu-latest
	steps:
	- name: Search requested review PR

syossan27 / code.rb

Created December 24, 2020 15:13

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

syossan27 / delete_all_rows.go

Created October 17, 2020 07:16

	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 / reverse_bit.go

Created October 17, 2020 06:12

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

syossan27 / spanner_delete_all_rows_by_multi_pk.go

Created September 11, 2020 14:50

Spannerのテーブルから全レコード削除する君２

	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 / spanner_delete_all_rows.go

Created September 11, 2020 12:23

Spannerのテーブルから全レコード削除する君

	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 / more_csutom.py

Last active April 26, 2020 09:11

	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 / postprocessing.py

Created April 26, 2020 09:04

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

Last active April 26, 2020 07:35

	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 / preprocessing.py

Created April 26, 2020 06:59

	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 syossan27