Simple Log Service:AccessKey ペアを使用せずに ECS インスタンス上の Simple Log Service SDK にアクセスする

Java 用 Simple Log Service SDK

1. Maven プロジェクトで Java 用 Simple Log Service SDK を使用するには、pom.xml ファイルに関連する依存関係を追加するだけです。詳細については、「Java 用 Simple Log Service SDK の概要」をご参照ください。

   重要

   SDK のバージョンが 0.6.110 以降であることを確認してください。

   <dependency>
       <groupId>com.aliyun.openservices</groupId>
       <artifactId>aliyun-log</artifactId>
       <version>0.6.110</version>
   </dependency>

2. Client クラスに作成されたインスタンス RAM ロールを指定します。詳細については、「ステップ 1：インスタンス RAM ロールを作成し、ECS インスタンスにアタッチする」をご参照ください。

   import com.aliyun.openservices.log.exception.LogException;
   import com.aliyun.openservices.log.response.GetProjectResponse;
   
   public class Main {
     public static void main(String[] args) throws LogException {
       // RoleName パラメーターを作成されたインスタンス RAM ロールに設定します。
       Client client = new Client("cn-hangzhou.log.aliyuncs.com", "RoleName");
       GetProjectResponse resp = client.GetProject("your-project");
       System.out.println(resp.GetProjectDescription());
     }
   }

Aliyun Log Java Producer

1. Maven プロジェクトで Aliyun Log Java Producer を使用するには、pom.xml ファイルに関連する依存関係を追加するだけです。詳細については、「Aliyun Log Java Producer」をご参照ください。

   重要

   Producer のバージョンが 0.3.22 以降であることを確認してください。

   <dependency>
       <groupId>com.aliyun.openservices</groupId>
       <artifactId>aliyun-log-producer</artifactId>
       <version>0.3.22</version>
   </dependency>

2. プロジェクト設定 の ProjectConfig パラメーターに作成されたインスタンス RAM ロールを指定します。詳細については、「ステップ 1：インスタンス RAM ロールを作成し、ECS インスタンスにアタッチする」をご参照ください。

   import com.aliyun.openservices.aliyun.log.producer.*;
   import com.aliyun.openservices.aliyun.log.producer.errors.ProducerException;
   import com.aliyun.openservices.log.common.LogItem;
   import com.aliyun.openservices.log.common.auth.CredentialsProvider;
   import com.aliyun.openservices.log.common.auth.ECSRoleCredentialsProvider;
   
   public class ExampleUsage {
   
       public static void main(String[] args) throws ProducerException, InterruptedException {
           String endpoint = "cn-hangzhou.log.aliyuncs.com";
           String project = "your-project";
           String logStore = "your-logstore";
           // ProducerConfig パラメーターを設定します。
           Config producerConfig = new ProducerConfig();
           // Producer を作成します。
           Producer producer = new LogProducer(new ProducerConfig());
           // your-ecs-ram-role-name を作成されたインスタンス RAM ロールに置き換えます。
           CredentialsProvider provider = new ECSRoleCredentialsProvider("your-ecs-ram-role-name");
           // プロジェクトを設定します。
           ProjectConfig projectConfig = new ProjectConfig(project, endpoint, provider, null);
           producer.putProjectConfig(projectConfig);
   
           // ログを送信します
           producer.send(project, logStore, buildLogItem());
           producer.send(project, logStore, null, null, buildLogItem());
           producer.send(project, logStore, "", "", buildLogItem());
           producer.close();
       }
   
       public static LogItem buildLogItem() {
           LogItem logItem = new LogItem();
           logItem.PushBack("k1", "v1");
           logItem.PushBack("k2", "v2");
           return logItem;
       }
   }
   

Aliyun Log Java Consumer

1. Maven プロジェクトで Aliyun Log Java Consumer を使用するには、pom.xml ファイルに関連する依存関係を追加するだけです。詳細については、「コンシューマーグループを使用してログを消費する」をご参照ください。

   重要

   Consumer のバージョンが 0.6.47 以降であることを確認してください。

   <dependency>
     <groupId>com.aliyun.openservices</groupId>
     <artifactId>loghub-client-lib</artifactId>
     <version>0.6.47</version>
   </dependency>

2. コンシューマーを作成する ために、LogHubConfig パラメーターに作成されたインスタンス RAM ロールを指定します。詳細については、「ステップ 1：インスタンス RAM ロールを作成し、ECS インスタンスにアタッチする」をご参照ください。

   import com.aliyun.openservices.log.common.auth.ECSRoleCredentialsProvider;
   import com.aliyun.openservices.log.common.auth.CredentialsProvider;
   import com.aliyun.openservices.loghub.client.ClientWorker;
   import com.aliyun.openservices.loghub.client.config.LogHubConfig;
   import com.aliyun.openservices.loghub.client.exceptions.LogHubClientWorkerException;
   
   public class Main {
       private static String Endpoint = "cn-hangzhou.log.aliyuncs.com";
       private static String Project = "your-project";
       private static String Logstore = "your-logstore";
       private static String ConsumerGroup = "consumerGroupX";
   
       public static void main(String[] args) throws LogHubClientWorkerException, InterruptedException {
           // your-ecs-ram-role-name を作成されたインスタンス RAM ロールに置き換えます。
           CredentialsProvider provider = new ECSRoleCredentialsProvider("your-ecs-ram-role-name");
   
           LogHubConfig config = new LogHubConfig(ConsumerGroup, "consumer_1", Endpoint, Project, Logstore, provider,
                   LogHubConfig.ConsumePosition.BEGIN_CURSOR);
           config.setMaxFetchLogGroupSize(1000);
   
           ClientWorker worker = new ClientWorker(new SampleLogHubProcessorFactory(), config);
           Thread thread = new Thread(worker);
           thread.start();
           Thread.sleep(60 * 60 * 1000);
           worker.shutdown();
           Thread.sleep(30 * 1000);
       }
   }

Go 用 Simple Log Service

provider パラメーターに作成されたインスタンス RAM ロールを指定します。詳細については、「ステップ 1：インスタンス RAM ロールを作成し、ECS インスタンスにアタッチする」をご参照ください。

package main

import (
	"fmt"

	sls "github.com/aliyun/aliyun-log-go-sdk"
)

func main() {
        // Simple Log Service エンドポイント。この例では、中国 (成都) リージョンの Simple Log Service エンドポイントが使用されています。パラメーター値を実際のエンドポイントに置き換えます。
	Endpoint := "cn-chengdu.log.aliyuncs.com"
	// your-ecs-ram-role-name を作成されたインスタンス RAM ロールに置き換えます。
	provider := sls.NewEcsRamRoleCredentialsProvider("your-ecs-ram-role-name")
	// Simple Log Service クライアントを作成します。
	client := sls.CreateNormalInterfaceV2(Endpoint, provider)
	resp, err := client.GetProject("your-project")
	if err != nil {
		panic(err)
	}
	fmt.Println(resp.Description)
}

Aliyun Log Go Producer

ProducerConfig 設定の provider パラメーターに作成されたインスタンス RAM ロールを指定します。詳細については、「ステップ 1：インスタンス RAM ロールを作成し、ECS インスタンスにアタッチする」をご参照ください。

package main

import (
	"fmt"
	"os"
	"os/signal"
	"sync"
	"time"

	sls "github.com/aliyun/aliyun-log-go-sdk"
	"github.com/aliyun/aliyun-log-go-sdk/producer"
	"github.com/gogo/protobuf/proto"
)

func main() {
	producerConfig := producer.GetDefaultProducerConfig()
	producerConfig.Endpoint = "cn-hangzhou.log.aliyuncs.com"
    // your-ecs-ram-role-name を作成されたインスタンス RAM ロールに置き換えます。
	provider := sls.NewEcsRamRoleCredentialsProvider("your-ecs-ram-role-name")
	producerConfig.CredentialsProvider = provider
	producerInstance := producer.InitProducer(producerConfig)
	ch := make(chan os.Signal)
	signal.Notify(ch, os.Kill, os.Interrupt)
	producerInstance.Start()
    
	var m sync.WaitGroup
	for i := 0; i < 10; i++ {
		m.Add(1)
		go func() {
			defer m.Done()
			for i := 0; i < 1000; i++ {
				log := producer.GenerateLog(uint32(time.Now().Unix()), map[string]string{"content": "test", "content2": fmt.Sprintf("%v", i)})
				err := producerInstance.SendLog("log-project", "log-store", "topic", "127.0.0.1", log)
				if err != nil {
					fmt.Println(err)
				}
			}
		}()
	}
	m.Wait()
	fmt.Println("送信完了")
	if _, ok := <-ch; ok {
		fmt.Println("シャットダウンシグナルを受信し、シャットダウンを開始します")
		producerInstance.Close(60000)
	}
}

Aliyun Log Go Consumer

CredentialsProvider パラメーターに作成されたインスタンス RAM ロールを指定します。詳細については、「ステップ 1：インスタンス RAM ロールを作成し、ECS インスタンスにアタッチする」をご参照ください。

package main

import (
	"fmt"
	"os"
	"os/signal"
	"syscall"

	sls "github.com/aliyun/aliyun-log-go-sdk"
	consumerLibrary "github.com/aliyun/aliyun-log-go-sdk/consumer"
	"github.com/go-kit/kit/log/level"
)

func main() {
	option := consumerLibrary.LogHubConfig{
		Endpoint: "cn-hangzhou.log.aliyuncs.com",
		// your-ecs-ram-role-name を作成されたインスタンス RAM ロールに置き換えます。
		CredentialsProvider: sls.NewEcsRamRoleCredentialsProvider("your-ecs-ram-role-name"),
		Project:             "your-project",
		Logstore:            "your-logstore",
		ConsumerGroupName:   "your-consumer-group",
		ConsumerName:        "your-consumer-group-consumer-1",
		CursorPosition:      consumerLibrary.END_CURSOR,
	}

	consumerWorker := consumerLibrary.InitConsumerWorkerWithCheckpointTracker(option, process)
	ch := make(chan os.Signal, 1)
	signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM)
	consumerWorker.Start()
	if _, ok := <-ch; ok {
		level.Info(consumerWorker.Logger).Log("msg", "停止シグナルを受信し、コンシューマーワーカーの停止を開始します", "consumer worker name", option.ConsumerName)
		consumerWorker.StopAndWait()
	}
}

// データ消費ロジック。
func process(shardId int, logGroupList *sls.LogGroupList, checkpointTracker consumerLibrary.CheckPointTracker) (string, error) {
	fmt.Println(shardId, logGroupList)
	checkpointTracker.SaveCheckPoint(false)
	return "", nil
}