SwiftでTwitter API v2のBatch ComplianceをGoogle Cloud Storageにアップロードする方法🐦

はじめに (対象読者・この記事でわかること)

この記事は、Swiftを使ったiOSアプリ開発に興味があり、Twitter API v2のBatch Compliance（Compliance Firehose API）を利用してデータをGoogle Cloud Storageにアップロードしたい開発者を対象としています。特に、Twitterのデータを安全かつ効率的に保存・管理する必要がある方に役立つ内容です。

この記事を読むことで、Twitter API v2のBatch ComplianceをSwiftで利用する方法、Google Cloud Storageへのアップロード実装、エラーハンドリング、そしてセキュリティ対策について理解できるようになります。実際のコード例を交えて具体的な実装手順を解説するので、初心者から中級者までスムーズに実装を進められるでしょう。

前提知識

この記事を読み進める上で、以下の知識があるとスムーズです。 前提となる知識1: Swiftの基本的な文法とiOSアプリ開発の基礎 前提となる知識2: REST APIの基本的な概念と利用方法 前提となる知識3: Google Cloud Platformの基本的な利用方法 前提となる知識4: Twitter Developerアカウントの取得とAPIキーの管理方法

Twitter API v2のBatch Complianceとは

Twitter API v2のBatch Compliance（Compliance Firehose API）は、Twitterプラットフォーム上のコンテンツに関するデータを提供するエンドポイントです。このAPIは、法的要件やコンプライアンス目的で、ツイートやユーザー情報の削除要求を追跡するために設計されています。

Batch Complianceを利用することで、特定のユーザーやツイートに関するコンプライアンスイベント（削除、非公開化など）をリアルタイムで取得できます。これにより、プラットフォームポリシーに準拠したコンテンツ管理が可能になります。

Google Cloud Storage（GCS）は、Googleが提供するオブジェクトストレージサービスです。スケーラブルで高可用性なストレージを提供し、大量のデータを安全に保存・管理できます。Twitter API v2のBatch Complianceで取得したデータをGCSに保存することで、後からの分析や監査が容易になります。

SwiftでBatch ComplianceとGoogle Cloud Storageを連携する実装

それでは、Swiftを使用してTwitter API v2のBatch Complianceからデータを取得し、Google Cloud Storageにアップロードする具体的な実装手順を解説します。

環境準備

まず、必要なライブラリをプロジェクトに追加します。CocoaPodsを使用する場合、Podfileに以下を記述します。

Ruby

pod 'GoogleCloudStorage'
pod 'TwitterKit'

その後、ターミナルでpod installを実行してライブラリをインストールします。

認証設定

Twitter APIとGoogle Cloud Storageの両方にアクセスするための認証設定を行います。

Swift

import TwitterKit
import GoogleCloudStorage

// Twitter APIの認証
Twitter.sharedInstance().start(withConsumerKey: "YOUR_CONSUMER_KEY", consumerSecret: "YOUR_CONSUMER_SECRET")

// Google Cloud Storageの認証
let storage = GCSStorage()
let bucket = storage.bucket(name: "YOUR_BUCKET_NAME")

Batch Complianceデータの取得

Twitter API v2のBatch Complianceエンドポイントからデータを取得します。

Swift

import Foundation

struct ComplianceJob: Codable {
    let id: String
    let type: String
    let createdAt: String
    let complianceJobType: String
    let status: String
    let error: String?
    let createdBy: String
    let name: String
    let resumable: Bool
}

struct ComplianceEvent: Codable {
    let id: String
    let createdAt: String
    let type: String
    let userId: String?
    let tweetId: String?
    let url: String?
}

func fetchComplianceJobs() async throws -> [ComplianceJob] {
    guard let url = URL(string: "https://api.twitter.com/2/compliance/jobs") else {
        throw URLError(.badURL)
    }

    let request = URLRequest(url: url)
    let (data, response) = try await URLSession.shared.data(for: request)

    guard let httpResponse = response as? HTTPURLResponse, httpResponse.statusCode == 200 else {
        throw URLError(.badServerResponse)
    }

    let decoder = JSONDecoder()
    let response = try decoder.decode(ComplianceJobsResponse.self, from: data)
    return response.data
}

func fetchComplianceEvents(jobId: String) async throws -> [ComplianceEvent] {
    guard let url = URL(string: "https://api.twitter.com/2/compliance/jobs/\(jobId)/events") else {
        throw URLError(.badURL)
    }

    let request = URLRequest(url: url)
    let (data, response) = try await URLSession.shared.data(for: request)

    guard let httpResponse = response as? HTTPURLResponse, httpResponse.statusCode == 200 else {
        throw URLError(.badServerResponse)
    }

    let decoder = JSONDecoder()
    let response = try decoder.decode(ComplianceEventsResponse.self, from: data)
    return response.data
}

Google Cloud Storageへのアップロード

取得したデータをGoogle Cloud Storageにアップロードします。

Swift

func uploadToGCS(data: Data, fileName: String) async throws {
    let metadata = GCSObjectMetadata()
    metadata.contentType = "application/json"
    metadata.contentEncoding = "gzip"

    let object = bucket.object(name: fileName)
    let writer = try object.writer(metadata: metadata)

    try writer.write(data)
    try writer.close()
}

func processComplianceData() async {
    do {
        // コンプライアンスジョブの取得
        let jobs = try await fetchComplianceJobs()

        for job in jobs {
            guard job.status == "complete" else { continue }

            // コンプライアンスイベントの取得
            let events = try await fetchComplianceEvents(jobId: job.id)

            // データをJSONに変換
            let encoder = JSONEncoder()
            encoder.outputFormatting = .prettyPrinted
            let jsonData = try encoder.encode(events)

            // 圧縮
            if let compressedData = try jsonData.gzipped() {
                // ファイル名の生成（日時とジョブIDを使用）
                let formatter = DateFormatter()
                formatter.dateFormat = "yyyyMMdd_HHmmss"
                let timestamp = formatter.string(from: Date())
                let fileName = "compliance_\(job.id)_\(timestamp).json.gz"

                // Google Cloud Storageにアップロード
                try await uploadToGCS(data: compressedData, fileName: fileName)

                print("アップロード完了: \(fileName)")
            }
        }
    } catch {
        print("エラーが発生しました: \(error)")
    }
}

非同期処理の実行

非同期処理を実行するための準備と実行コードです。

Swift

// 非同期処理を実行
Task {
    await processComplianceData()
}

エラーハンドリングの実装

実装中に遭遇する可能性のあるエラーとその対処法です。

Swift

// カスタムエラーの定義
enum ComplianceError: Error {
    case invalidJobStatus
    case dataConversionFailed
    case uploadFailed(Error)
    case apiError(Error)
}

// エラーハンドリングを含んだ処理
func processComplianceDataWithErrorHandling() async {
    do {
        let jobs = try await fetchComplianceJobs()

        for job in jobs {
            // ジョブの状態チェック
            guard job.status == "complete" else {
                throw ComplianceError.invalidJobStatus
            }

            do {
                let events = try await fetchComplianceEvents(jobId: job.id)

                let encoder = JSONEncoder()
                encoder.outputFormatting = .prettyPrinted

                guard let jsonData = try? encoder.encode(events) else {
                    throw ComplianceError.dataConversionFailed
                }

                if let compressedData = try? jsonData.gzipped() {
                    let formatter = DateFormatter()
                    formatter.dateFormat = "yyyyMMdd_HHmmss"
                    let timestamp = formatter.string(from: Date())
                    let fileName = "compliance_\(job.id)_\(timestamp).json.gz"

                    do {
                        try await uploadToGCS(data: compressedData, fileName: fileName)
                        print("アップロード完了: \(fileName)")
                    } catch {
                        throw ComplianceError.uploadFailed(error)
                    }
                }
            } catch {
                throw ComplianceError.apiError(error)
            }
        }
    } catch ComplianceError.invalidJobStatus {
        print("ジョブが完了していません")
    } catch ComplianceError.dataConversionFailed {
        print("データの変換に失敗しました")
    } catch ComplianceError.uploadFailed(let error) {
        print("アップロードに失敗しました: \(error.localizedDescription)")
    } catch ComplianceError.apiError(let error) {
        print("APIエラーが発生しました: \(error.localizedDescription)")
    } catch {
        print("予期せぬエラーが発生しました: \(error.localizedDescription)")
    }
}

セキュリティ対策

APIキーや認証情報の安全な管理方法です。

Swift

// Info.plistからAPIキーを取得
func getTwitterAPIKeys() -> (consumerKey: String, consumerSecret: String)? {
    guard let path = Bundle.main.path(forResource: "Info", ofType: "plist"),
          let dict = NSDictionary(contentsOfFile: path),
          let consumerKey = dict["TwitterConsumerKey"] as? String,
          let consumerSecret = dict["TwitterConsumerSecret"] as? String else {
        return nil
    }
    return (consumerKey, consumerSecret)
}

// Google Cloudサービスアカウントの認証
func setupGCSAuthentication() {
    guard let serviceAccountKeyPath = Bundle.main.path(forResource: "service-account", ofType: "json") else {
        print("サービスアカウントキーファイルが見つかりません")
        return
    }

    do {
        let serviceAccountKeyData = try Data(contentsOf: URL(fileURLWithPath: serviceAccountKeyPath))
        let serviceAccountKey = try JSONDecoder().decode(ServiceAccountKey.self, from: serviceAccountKeyData)

        let credentials = GCPCredentials(serviceAccount: serviceAccountKey)
        GCSStorage.shared.setup(credentials: credentials)
    } catch {
        print("認証の設定に失敗しました: \(error)")
    }
}

// サービスアカウントキーの構造体
struct ServiceAccountKey: Codable {
    let type: String
    let project_id: String
    let private_key_id: String
    let private_key: String
    let client_email: String
    let client_id: String
    let auth_uri: String
    let token_uri: String
    let auth_provider_x509_cert_url: String
    let client_x509_cert_url: String
}

まとめ

本記事では、Swiftを使用してTwitter API v2のBatch ComplianceをGoogle Cloud Storageにアップロードする方法について解説しました。

• Twitter API v2のBatch Complianceの基本的な使い方を理解しました
• Google Cloud Storageへのデータアップロードを実装しました
• 非同期処理とエラーハンドリングのベストプラクティスを学びました
• セキュリティ対策を施した安全な実装方法を把握しました

この記事を通して、Twitterのデータを安全かつ効率的に保存・管理するための技術的な知識を得られたことと思います。今後は、取得したデータの分析や可視化、自動化パイプラインの構築など、発展的な内容についても記事にする予定です。

参考資料

• Twitter API v2 Documentation - Compliance Jobs
• Google Cloud Storage Documentation
• Twitter Developer Portal
• Swift Concurrency: async/await
• Google Cloud Storage Swift Client Library