Simple Log Service:アクセスキーなしで ECS 上の SLS SDK を使用する

Java SDK

1. Maven プロジェクトで SLS SDK for Java を使用するには、pom.xml ファイルに次の依存関係を追加します。詳細については、「SLS SDK for Java」をご参照ください。

   重要

   SLS SDK for Java の最小必須バージョンは 0.6.110 です。

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

2. Client クラスに、ステップ 1 で作成したインスタンス RAM ロールの名前を入力パラメータとして渡します。

   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());
     }
   }

Java Producer

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

   重要

   Aliyun Log Java Producer の最小必須バージョンは 0.3.22 です。

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

2. ログプロジェクトの設定で、ProjectConfig パラメータに ステップ 1 で作成したインスタンス RAM ロールの名前を指定します。

   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;
       }
   }
   

Java Consumer

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

   重要

   Aliyun Log Java Consumer の最小必須バージョンは 0.6.47 です。

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

2. コンシューマーの作成では、LogHubConfig パラメータを ステップ 1 で作成したインスタンス RAM ロールの名前に設定します。

   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 SDK

provider には、ステップ 1 で作成したインスタンス RAM ロールの名前を指定します。

package main
import (
	"fmt"
	sls "github.com/aliyun/aliyun-log-go-sdk"
)
func main() {
        // SLS のエンドポイント。この例では中国 (成都) リージョンを使用しています。実際のエンドポイントに置き換えてください。
	Endpoint := "cn-chengdu.log.aliyuncs.com"
	// your-ecs-ram-role-name を作成した RAM ロールの名前に置き換えます。
	provider := sls.NewEcsRamRoleCredentialsProvider("your-ecs-ram-role-name")
	// SLS クライアントを作成します。
	client := sls.CreateNormalInterfaceV2(Endpoint, provider)
	resp, err := client.GetProject("your-project")
	if err != nil {
		panic(err)
	}
	fmt.Println(resp.Description)
}

Go Producer

ProducerConfig の設定で、provider パラメータを ステップ 1 で作成したインスタンス RAM ロールの名前に設定します。

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("Send completion")
	if _, ok := <-ch; ok {
		fmt.Println("Get the shutdown signal and start to shut down")
		producerInstance.Close(60000)
	}
}

Go Consumer

CredentialsProvider 入力パラメータには、ステップ 1 で作成したインスタンス RAM ロールの名前を渡します。

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", "get stop signal, start to stop consumer worker", "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
}