Simple Log Service:Akses Simple Log Service SDK pada instance ECS tanpa pasangan AccessKey

Simple Log Service SDK for Java

1. Untuk menggunakan Simple Log Service SDK for Java dalam proyek Maven, tambahkan dependensi terkait ke file pom.xml. Untuk informasi lebih lanjut, lihat Ikhtisar Simple Log Service SDK for Java.

   Penting

   Pastikan versi SDK adalah 0.6.110 atau lebih baru.

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

2. Tentukan Peran RAM instance yang dibuat untuk kelas Client. Untuk informasi lebih lanjut, lihat Langkah 1: Buat Peran RAM Instance dan Lampirkan Peran ke Instance 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 {
       // Atur parameter RoleName ke peran RAM instance yang dibuat.
       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. Untuk menggunakan Aliyun Log Java Producer dalam proyek Maven, tambahkan dependensi terkait ke file pom.xml. Untuk informasi lebih lanjut, lihat Aliyun Log Java Producer.

   Penting

   Pastikan versi Producer adalah 0.3.22 atau lebih baru.

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

2. Tentukan Peran RAM instance yang dibuat untuk parameter ProjectConfig dalam pengaturan proyek. Untuk informasi lebih lanjut, lihat Langkah 1: Buat Peran RAM Instance dan Lampirkan Peran ke Instance 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";
           // Konfigurasikan parameter ProducerConfig.
           Config producerConfig = new ProducerConfig();
           // Buat produser.
           Producer producer = new LogProducer(new ProducerConfig());
           // Ganti your-ecs-ram-role-name dengan peran RAM instance yang dibuat.
           CredentialsProvider provider = new ECSRoleCredentialsProvider("your-ecs-ram-role-name");
           // Konfigurasikan proyek.
           ProjectConfig projectConfig = new ProjectConfig(project, endpoint, provider, null);
           producer.putProjectConfig(projectConfig);
   
           // kirim log
           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. Untuk menggunakan Aliyun Log Java Consumer dalam proyek Maven, tambahkan dependensi terkait ke file pom.xml. Untuk informasi lebih lanjut, lihat Gunakan Grup Konsumen untuk Mengonsumsi Log.

   Penting

   Pastikan versi Consumer adalah 0.6.47 atau lebih baru.

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

2. Tentukan Peran RAM instance yang dibuat untuk parameter LogHubConfig untuk membuat konsumen. Untuk informasi lebih lanjut, lihat Langkah 1: Buat Peran RAM Instance dan Lampirkan Peran ke Instance 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 {
           // Ganti your-ecs-ram-role-name dengan peran RAM instance yang dibuat.
           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);
       }
   }

Simple Log Service for Go

Tentukan Peran RAM instance yang dibuat untuk parameter provider. Untuk informasi lebih lanjut, lihat Langkah 1: Buat Peran RAM Instance dan Lampirkan Peran ke Instance ECS.

package main

import (
	"fmt"

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

func main() {
        // Titik akhir Simple Log Service. Dalam contoh ini, titik akhir Simple Log Service untuk wilayah China (Hangzhou) digunakan. Ganti nilai parameter dengan titik akhir sebenarnya. 
	Endpoint := "cn-chengdu.log.aliyuncs.com"
	// Ganti your-ecs-ram-role-name dengan peran RAM instance yang dibuat.
	provider := sls.NewEcsRamRoleCredentialsProvider("your-ecs-ram-role-name")
	// Buat klien 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

Tentukan Peran RAM instance yang dibuat untuk parameter provider dalam pengaturan ProducerConfig. Untuk informasi lebih lanjut, lihat Langkah 1: Buat Peran RAM Instance dan Lampirkan Peran ke Instance 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"
    // Ganti your-ecs-ram-role-name dengan peran RAM instance yang dibuat.
	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("Pengiriman selesai")
	if _, ok := <-ch; ok {
		fmt.Println("Dapatkan sinyal shutdown dan mulai shutdown")
		producerInstance.Close(60000)
	}
}

Aliyun Log Go Consumer

Tentukan Peran RAM instance yang dibuat untuk parameter CredentialsProvider. Untuk informasi lebih lanjut, lihat Langkah 1: Buat Peran RAM Instance dan Lampirkan Peran ke Instance 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",
		// Ganti your-ecs-ram-role-name dengan peran RAM instance yang dibuat.
		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", "dapatkan sinyal stop, mulai hentikan pekerja konsumen", "nama pekerja konsumen", option.ConsumerName)
		consumerWorker.StopAndWait()
	}
}

// Logika konsumsi data.
func process(shardId int, logGroupList *sls.LogGroupList, checkpointTracker consumerLibrary.CheckPointTracker) (string, error) {
	fmt.Println(shardId, logGroupList)
	checkpointTracker.SaveCheckPoint(false)
	return "", nil
}