# 必要なライブラリをインポートします。
import time
from tencentcloud.log.logclient import LogClient
from tencentcloud.log.logexception import LogException
from tencentcloud.log.cls_pb2 import LogGroupList
import os

def upload(topic_id, client):
    LogLogGroupList = LogGroupList()
    LogGroup = LogLogGroupList.logGroupList.add()
    # 今回のログアップロードのファイル名ソースをカスタマイズします。これはメタデータフィールドとしてログに含まれます。
    LogGroup.filename = "pyXXXX.log"
    # 今回のアップロードのアドレスソースをカスタマイズします。これはメタデータフィールドとしてログに含まれます。
    LogGroup.source = "192.XX.XX.XX"
    # カスタムメタデータフィールド。
    LogTag = LogGroup.logTags.add()
    LogTag.key = "key"  
    LogTag.value = "value"  
    
    Log = LogGroup.logs.add()
    Log.time = int(round(time.time() * 1000000))  # 現在時刻をログのタイムスタンプとして取得します。
    
    # ログの内容を定義します。
    Content = Log.contents.add()
    Content.key = "Hello"  
    Content.value = "World"  
    
    try:
        request = client.put_log_raw(topic_id, LogLogGroupList)
        print("Request ID:", request.get_request_id())  
    except LogException as e:
        print("Error uploading log:", e)  
    except Exception as e:
        # ネットワーク接続など、その他の潜在的な問題をカバーするように例外キャッチを拡張します。
        print("Unexpected Error:", e)
        
if __name__ == '__main__':

    # ドメイン名情報を入力します。入力ガイド：https://www.tencentcloud.com/document/product/614/18940#.E5.9F.9F.E5.90.8D。リンク内のAPIログアップロードタブにあるドメイン名を参照してください。
    endpoint = 'https://ap-xxxxxxxx.cls.tencentcs.com'
        
    # TencentCloud APIキー情報を入力してください。キー情報の取得はこちらから：https://console.tencentcloud.com/cam/capi
    # また、キーに関連付けられたアカウントに、対応するログアップロード権限が付与されていることを確認してください。権限設定ガイド：https://www.tencentcloud.com/document/product/614/45004#.E4.BD.BF.E7.94.A8-api-.E4.B8.8A.E4.BC.A0.E6.95.B0.E6.8D.AE
    # この例では環境変数から取得します。環境変数の設定ガイド：https://www.tencentcloud.com/document/product/614/113851?from_cn_redirect=1
    accessKeyId = os.environ["TENCENTCLOUD_SECRET_ID"]
    accessKey = os.environ["TENCENTCLOUD_SECRET_KEY"]
    
    
    if not accessKeyId or not accessKey:
       raise EnvironmentError("Error: TENCENTCLOUD_SECRET_ID または TENCENTCLOUD_SECRET_KEY が設定されていません")

    
    # ログトピックのIDを入力してください。
    topic_id = '59XXXXXXXXXXXXXXXXXXXXXXXXXXXXXX'
   
    if not endpoint.strip():
        raise ValueError("endpoint は空にできません。正しいCLSドメインを入力してください")
    if not topic_id.strip():
        raise ValueError("topic_id は空にできません。正しいログトピックIDを入力してください")
       
    # ログクライアントを構築します。
    client = LogClient(endpoint, accessKeyId, accessKey)
    # アップロード関数を呼び出します。
    upload(topic_id, client)