入出力

Go言語でCSVファイルを読み込む方法を解説

2025-02-20更新日: 2025-02-20

Go言語でCSVファイルを読み込む方法について、わかりやすく解説します。

開発環境が整っている前提で、基本的な実行手順と実装例を交えながら説明します。

CSV特有のポイントを押さえ、実用的なコード例を参考にしながら学習できる内容です。

目次から探す

CSVパッケージの基本認識
- csvパッケージの概要と特徴
- osパッケージとの連携
CSV読み込みの実装手順
実装例の詳細解説
- コード例の構成
- 結果の取得と出力
エラー処理とパフォーマンス対策
- エラーの検知とハンドリング
- パフォーマンス改善のポイント
CSV読み込み応用例
- ヘッダー行の処理方法
- 特殊フォーマットへの対応
まとめ

CSVパッケージの基本認識

csvパッケージの概要と特徴

インポート方法と基本構文

Goの標準ライブラリに含まれるcsvパッケージは、CSVファイルの読み込みや書き込みを簡単に行える機能を提供しています。

まずは、以下のようにインポートすることで利用できるようになります。

package main
import (
    "encoding/csv" // CSV操作用パッケージ
    "fmt"          // 出力用パッケージ
)
func main() {
    // csvパッケージが正しくインポートされたか確認するためのサンプルコードです
    fmt.Println("csvパッケージを利用できます")
}

csvパッケージを利用できます

主要関数の紹介

csvパッケージでは、以下の主要な関数が利用可能です。

csv.NewReader(file)

ファイルからCSVデータを読み込むためのリーダーを初期化します。

(r *Reader) Read()

CSVの1行分のレコードを読み込みます。

(r *Reader) ReadAll()

CSV全体を読み込み、2次元スライスに格納します。

これらの関数を組み合わせることで、柔軟なCSVファイルの操作が可能となります。

osパッケージとの連携

ファイル操作の基本

CSVファイルの読み込みでは、osパッケージによるファイルのオープンやクローズが重要な役割を果たします。

以下のサンプルでは、指定したファイルパスからCSVファイルをオープンし、エラー処理も行っています。

package main
import (
    "fmt"
    "os"
)
func main() {
    filePath := "sample.csv" // オープンするCSVファイルのパス
    file, err := os.Open(filePath) // ファイルをオープン
    if err != nil {
        fmt.Println("ファイルオープンエラー:", err)
        return
    }
    // 終了時には必ずファイルをクローズする
    defer file.Close()
    fmt.Println("ファイルオープン成功")
}

ファイルオープン成功

CSV読み込みの実装手順

ファイルのオープンとエラー処理

ファイルパス指定とos.Openの利用

CSVファイルの読み込みでは、まずos.Openを利用し、適切なファイルパスを指定する必要があります。

ファイルパスの指定が正しければ、ファイルが開かれ、次の処理へ移行できます。

package main
import (
    "fmt"
    "os"
)
func main() {
    filePath := "sample.csv" // 読み込み対象のファイルパスを指定
    file, err := os.Open(filePath)
    if err != nil {
        fmt.Println("ファイルオープンエラー:", err)
        return
    }
    defer file.Close()
    fmt.Println("ファイルが正常にオープンされました")
}

ファイルが正常にオープンされました

エラー検出と対処方法

ファイル操作においては、エラーが発生した場合に早期に検出し、処理を中断することが重要です。

以下のコードでは、ファイルオープン時とCSV読み込み時にエラーを検出し、適切に出力しています。

package main
import (
    "fmt"
    "os"
)
func main() {
    filePath := "sample.csv"
    file, err := os.Open(filePath)
    if err != nil {
        fmt.Println("ファイルオープンエラー:", err)
        return
    }
    defer file.Close()
    // ファイルがオープンされたことを確認後、次の処理に進む
    fmt.Println("ファイルオープン成功！")
}

ファイルオープン成功！

csv.Readerの初期化と設定

csv.NewReaderの使い方

CSVファイルを扱うためには、csv.NewReaderを用いてリーダーを初期化します。

次のサンプルでは、ファイルを開いた後、リーダーを生成し、ReadAll()で全データを取得する流れを示しています。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("sample.csv")
    if err != nil {
        fmt.Println("ファイル読み込みエラー:", err)
        return
    }
    defer file.Close()
    // csv.Readerの初期化
    reader := csv.NewReader(file)
    records, err := reader.ReadAll() // CSV全体を読み込む
    if err != nil {
        fmt.Println("CSV読み込みエラー:", err)
        return
    }
    fmt.Println("CSVデータ:", records)
}

CSVデータ: [[データ1 データ2] [情報1 情報2]]

カスタムデリミタの設定例

csvパッケージでは、デフォルトの区切り文字(カンマ)以外にも、任意の区切り文字を設定できます。

以下の例では、セミコロン区切りのCSVファイルを読み込むために、reader.Commaに';'を設定しています。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("sample_semicolon.csv")
    if err != nil {
        fmt.Println("ファイルオープンエラー:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    reader.Comma = ';' // 区切り文字をセミコロンに変更
    records, err := reader.ReadAll()
    if err != nil {
        fmt.Println("CSV読み込みエラー:", err)
        return
    }
    fmt.Println("CSVデータ:", records)
}

CSVデータ: [[項目1 項目2] [値1 値2]]

レコードのパース処理

1行ずつの読み込み方法

全体を一度に読み込むReadAll()ではなく、Read()を利用して1行ずつ処理する方法もあります。

これにより、メモリ使用量を抑えつつ、動的にCSVデータを扱うことが可能です。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("sample.csv")
    if err != nil {
        fmt.Println("ファイルエラー:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    // 終了まで1行ずつ読み込む
    for {
        record, err := reader.Read()
        if err != nil {
            break
        }
        fmt.Println("1行のデータ:", record)
    }
}

1行のデータ: [データ1 データ2]
1行のデータ: [情報1 情報2]

データ型変換の工夫

CSVでは全てのデータが文字列として扱われますが、必要に応じて数値などに変換することができます。

以下の例では、文字列から整数へ変換する方法を示しています。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
    "strconv"
)
func main() {
    file, err := os.Open("sample_numeric.csv")
    if err != nil {
        fmt.Println("ファイルオープンエラー:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    records, err := reader.ReadAll()
    if err != nil {
        fmt.Println("CSV読み込みエラー:", err)
        return
    }
    // 数値変換の例。各行の最初の列を整数に変換する
    for _, row := range records {
        if len(row) > 0 {
            number, err := strconv.Atoi(row[0])
            if err != nil {
                fmt.Println("変換エラー:", err)
                continue
            }
            fmt.Println("変換後の数値:", number)
        }
    }
}

変換後の数値: 123
変換後の数値: 456

実装例の詳細解説

コード例の構成

メイン関数の流れ

実際の実装例では、メイン関数でファイルをオープンし、csv.NewReaderによりCSVデータの読み込みを行い、補助関数にて処理を分担しています。

以下は、メイン関数と補助関数を組み合わせたサンプルコードです。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
// readCSV はファイルからCSVデータを読み込む補助関数です
func readCSV(filePath string) ([][]string, error) {
    file, err := os.Open(filePath)
    if err != nil {
        return nil, err
    }
    defer file.Close()
    reader := csv.NewReader(file)
    return reader.ReadAll()
}
func main() {
    filePath := "sample.csv" // CSVファイルのパスを指定
    records, err := readCSV(filePath) // 補助関数を利用しCSVデータを取得
    if err != nil {
        fmt.Println("CSV読み込みエラー:", err)
        return
    }
    fmt.Println("CSVデータの読み込みに成功")
    // 各レコードを出力する
    for _, record := range records {
        fmt.Println(record)
    }
}

CSVデータの読み込みに成功
[データ1 データ2]
[情報1 情報2]

補助関数の役割分担

このサンプルコードでは、readCSV関数がファイルオープンおよびCSVのパース処理を担当しています。

メイン関数は、エラーチェックと結果の出力に専念することで、処理の役割を明確にしています。

結果の取得と出力

スライスへのデータ格納方法

CSVの読み込み結果は、csv.ReadAll()により2次元のstringスライスとして格納されます。

下記の例では、CSVデータがどのようにスライスへ格納されるかを確認できます。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("sample.csv")
    if err != nil {
        fmt.Println("ファイルエラー:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    records, err := reader.ReadAll()
    if err != nil {
        fmt.Println("CSV読み込みエラー:", err)
        return
    }
    fmt.Println("格納されたレコード:")
    fmt.Println(records)
}

格納されたレコード:
[[データ1 データ2] [情報1 情報2]]

コンソール出力の実装例

CSVから取得したレコードを、コンソールに1行ずつ出力する例です。

出力内容を整形することで、データの確認が容易になります。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("sample.csv")
    if err != nil {
        fmt.Println("ファイルオープンエラー:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    records, err := reader.ReadAll()
    if err != nil {
        fmt.Println("CSV読み込みエラー:", err)
        return
    }
    // 各レコードを1行ずつ整形して出力する
    for index, record := range records {
        fmt.Printf("レコード%d: %v\n", index+1, record)
    }
}

レコード1: [データ1 データ2]
レコード2: [情報1 情報2]

エラー処理とパフォーマンス対策

エラーの検知とハンドリング

ログ出力によるエラー管理

標準パッケージのlogを利用することで、エラー発生時の状況を簡単に記録できます。

下記の例では、エラー発生時にログ出力を行い、後続処理を中断する方法を示しています。

package main
import (
    "encoding/csv"
    "log"
    "os"
)
func main() {
    file, err := os.Open("sample.csv")
    if err != nil {
        log.Println("ファイルオープンエラー:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    _, err = reader.ReadAll()
    if err != nil {
        log.Println("CSV読み込みエラー:", err)
        return
    }
    log.Println("CSVの読み込みに成功")
}

2023/10/10 12:00:00 CSVの読み込みに成功

早期リターンの実装例

エラーが発生した際に、すぐに処理を終了する早期リターンの実装は、無駄なリソース消費を防ぎます。

次のコードは、エラー発生時に早期リターンするシンプルな例です。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("sample.csv")
    if err != nil {
        fmt.Println("ファイル読み込み失敗:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    records, err := reader.ReadAll()
    if err != nil {
        fmt.Println("CSV読み込み失敗:", err)
        return
    }
    fmt.Println("処理継続")
    fmt.Println(records)
}

処理継続
[[データ1 データ2] [情報1 情報2]]

パフォーマンス改善のポイント

バッファ処理の活用

大きなCSVファイルの読み込み時には、bufio.Scannerなどのバッファ処理を併用することで、処理速度が向上します。

以下の例では、bufio.Scannerを利用して、ファイルを1行ずつ読み込みながら出力する方法を示しています。

package main
import (
    "bufio"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("sample.csv")
    if err != nil {
        fmt.Println("ファイルオープンエラー:", err)
        return
    }
    defer file.Close()
    // バッファを用いてファイルを1行ずつ読み込む
    scanner := bufio.NewScanner(file)
    for scanner.Scan() {
        line := scanner.Text() // 1行の文字列を取得
        fmt.Println("行:", line)
    }
    if err := scanner.Err(); err != nil {
        fmt.Println("スキャンエラー:", err)
    }
}

行: データ1,データ2
行: 情報1,情報2

大規模CSV対応の工夫

大規模なCSVファイルを扱う場合、全体を一度に読み込むのではなく、1行ずつ読み込むなど、メモリ消費を抑える工夫が必要になります。

下記の例は、大規模CSVファイルを効率的に処理するためのシンプルな実装例です。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("large_sample.csv")
    if err != nil {
        fmt.Println("ファイルオープンエラー:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    // 1行ずつ読み込み、データを処理する例
    for {
        record, err := reader.Read()
        if err != nil {
            break
        }
        fmt.Println("処理中のレコード:", record)
    }
}

処理中のレコード: [レコード1]
処理中のレコード: [レコード2]

CSV読み込み応用例

ヘッダー行の処理方法

ヘッダー行のスキップ方法

CSVファイルにヘッダー行が存在する場合、最初の行を読み飛ばした後にデータ行を処理する方法があります。

以下のサンプルコードでは、最初の1行をスキップしてから残りのデータを読み込んでいます。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("header_sample.csv")
    if err != nil {
        fmt.Println("ファイルオープンエラー:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    // ヘッダー行を読み飛ばす
    if _, err := reader.Read(); err != nil {
        fmt.Println("ヘッダー読み込みエラー:", err)
        return
    }
    records, err := reader.ReadAll()
    if err != nil {
        fmt.Println("CSV読み込みエラー:", err)
        return
    }
    fmt.Println("データ行:", records)
}

データ行: [[値1 値2] [値3 値4]]

データ行との振り分け

ヘッダー情報とデータ行を別々に管理することで、後続の処理がより柔軟になります。

次の例では、最初の行をヘッダーとして取得し、残りをデータ行として格納しています。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("header_sample.csv")
    if err != nil {
        fmt.Println("ファイルエラー:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    header, err := reader.Read() // ヘッダー行を取得
    if err != nil {
        fmt.Println("ヘッダー読み込みエラー:", err)
        return
    }
    records, err := reader.ReadAll() // 残りのデータ行を取得
    if err != nil {
        fmt.Println("CSVデータ読み込みエラー:", err)
        return
    }
    fmt.Println("ヘッダー:", header)
    fmt.Println("データ行:", records)
}

ヘッダー: [項目1 項目2]
データ行: [[値1 値2] [値3 値4]]

特殊フォーマットへの対応

区切り文字変更の設定例

標準のCSVはカンマ区切りですが、タブやセミコロンなど、独自の区切り文字に対応することも可能です。

以下の例では、タブ文字を区切り文字に設定してCSVファイルを読み込んでいます。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("tab_delimited.csv")
    if err != nil {
        fmt.Println("ファイルオープンエラー:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    reader.Comma = '\t' // 区切り文字をタブに設定
    records, err := reader.ReadAll()
    if err != nil {
        fmt.Println("CSV読み込みエラー:", err)
        return
    }
    fmt.Println("タブ区切りCSVデータ:", records)
}

タブ区切りCSVデータ: [[項目1 項目2] [値1 値2]]

独自フォーマット読み込みの工夫

CSVの形式が標準と異なる場合、カスタム設定により独自フォーマットにも対応できます。

以下のサンプルでは、パイプ文字|を区切り文字として設定しています。

package main
import (
    "encoding/csv"
    "fmt"
    "os"
)
func main() {
    file, err := os.Open("custom_format.csv")
    if err != nil {
        fmt.Println("ファイルオープンエラー:", err)
        return
    }
    defer file.Close()
    reader := csv.NewReader(file)
    reader.Comma = '|' // 区切り文字をパイプに設定
    records, err := reader.ReadAll()
    if err != nil {
        fmt.Println("CSV読み込みエラー:", err)
        return
    }
    fmt.Println("独自フォーマットCSVデータ:", records)
}

独自フォーマットCSVデータ: [[列1 列2] [データA データB]]

まとめ

この記事では、Go言語のcsvパッケージを利用して、CSVファイルの基本的な読み込み方法や各種設定、エラー処理、パフォーマンス向上策の実装例を詳しく紹介しました。

全体を通して、基本構文から応用例まで、CSVデータ操作の流れが体系的に理解できる内容でした。

ぜひ、実際にコードを試しながら、より効率的なCSVファイル処理の体験に挑戦してみてください。