Simple Log Service:Use the SLS SDK on ECS without an AccessKey

Java SDK

1. Para usar o Simple Log Service SDK for Java em um projeto Maven, adicione a dependência abaixo ao arquivo pom.xml. Para mais informações, consulte Simple Log Service SDK for Java.

   Importante

   A versão mínima exigida do Simple Log Service SDK for Java é a 0.6.110.

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

2. Na classe Client, passe o nome da função RAM de instância criada na Etapa 1 como parâmetro de entrada.

   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 {
       // Replace RoleName with the name of the RAM role that you created.
       Client client = new Client("cn-hangzhou.log.aliyuncs.com", "RoleName");
       GetProjectResponse resp = client.GetProject("your-project");
       System.out.println(resp.GetProjectDescription());
     }
   }

Java Producer

1. Para usar o Aliyun Log Java Producer em um projeto Maven, inclua a seguinte dependência no arquivo pom.xml. Consulte Aliyun Log Java Producer para mais detalhes.

   Importante

   A versão mínima necessária do Aliyun Log Java Producer é a 0.3.22.

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

2. Em Configurar um projeto de log, especifique o nome da função RAM de instância criada na Etapa 1 para o parâmetro ProjectConfig.

   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";
           // Configure ProducerConfig.
           Config producerConfig = new ProducerConfig();
           // Create a producer.
           Producer producer = new LogProducer(new ProducerConfig());
           // Replace your-ecs-ram-role-name with the name of the RAM role that you created.
           CredentialsProvider provider = new ECSRoleCredentialsProvider("your-ecs-ram-role-name");
           // Configure the project.
           ProjectConfig projectConfig = new ProjectConfig(project, endpoint, provider, null);
           producer.putProjectConfig(projectConfig);
           // Send logs.
           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. Para integrar o Aliyun Log Java Consumer em um projeto Maven, adicione a dependência abaixo ao arquivo pom.xml. Veja também Usar grupos de consumidores para consumir logs.

   Importante

   A versão mínima requerida do Aliyun Log Java Consumer é a 0.6.47.

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

2. Para criar um consumidor, defina o parâmetro LogHubConfig como o nome da função RAM de instância criada na Etapa 1.

   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 {
           // Replace your-ecs-ram-role-name with the name of the RAM role that you created.
           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

O parâmetro provider especifica o nome da função RAM de instância criada na Etapa 1.

package main
import (
	"fmt"
	sls "github.com/aliyun/aliyun-log-go-sdk"
)
func main() {
        // The endpoint of Simple Log Service. This example uses the China (Chengdu) region. Replace the value with the actual endpoint.
	Endpoint := "cn-chengdu.log.aliyuncs.com"
	// Replace your-ecs-ram-role-name with the name of the RAM role that you created.
	provider := sls.NewEcsRamRoleCredentialsProvider("your-ecs-ram-role-name")
	// Create a Simple Log Service client.
	client := sls.CreateNormalInterfaceV2(Endpoint, provider)
	resp, err := client.GetProject("your-project")
	if err != nil {
		panic(err)
	}
	fmt.Println(resp.Description)
}

Go Producer

Em Configurar ProducerConfig, defina o parâmetro provider como o nome da função RAM de instância criada na Etapa 1.

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"
    // Replace your-ecs-ram-role-name with the name of the RAM role that you created.
	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

Para o parâmetro de entrada CredentialsProvider, informe o nome da função RAM de instância criada na Etapa 1.

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",
		// Replace your-ecs-ram-role-name with the name of the RAM role that you created.
		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()
	}
}
// Implement the data consumption logic.
func process(shardId int, logGroupList *sls.LogGroupList, checkpointTracker consumerLibrary.CheckPointTracker) (string, error) {
	fmt.Println(shardId, logGroupList)
	checkpointTracker.SaveCheckPoint(false)
	return "", nil
}