You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2025/02/25 09:06:23 UTC
(iotdb-docs) branch main updated: Code example for logging in with username and password in the supplementary data subscription API (#599)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iotdb-docs.git
The following commit(s) were added to refs/heads/main by this push:
new eb19b190 Code example for logging in with username and password in the supplementary data subscription API (#599)
eb19b190 is described below
commit eb19b190c63bef968afc70e9d0adb3c4c8c03cc0
Author: W1y1r <15...@users.noreply.github.com>
AuthorDate: Tue Feb 25 17:06:18 2025 +0800
Code example for logging in with username and password in the supplementary data subscription API (#599)
---
src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md | 8 +++++---
src/UserGuide/V1.3.3/API/Programming-Data-Subscription.md | 9 +++++----
src/UserGuide/dev-1.3/API/Programming-Data-Subscription.md | 9 +++++----
src/UserGuide/latest/API/Programming-Data-Subscription.md | 8 +++++---
.../UserGuide/Master/Tree/API/Programming-Data-Subscription.md | 9 +++++----
src/zh/UserGuide/V1.3.3/API/Programming-Data-Subscription.md | 9 +++++----
src/zh/UserGuide/dev-1.3/API/Programming-Data-Subscription.md | 9 +++++----
src/zh/UserGuide/latest/API/Programming-Data-Subscription.md | 9 +++++----
8 files changed, 40 insertions(+), 30 deletions(-)
diff --git a/src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md b/src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
index 4c0b6730..9391c04a 100644
--- a/src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
+++ b/src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
public class DataConsumerExample {
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
- try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+ try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
// 1. open session
session.open();
@@ -114,7 +114,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
pullConsumer.subscribe("topic_all");
@@ -161,7 +162,8 @@ public class DataConsumerExample {
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
// 2. Specify the consumption type as the tsfile type
- consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
diff --git a/src/UserGuide/V1.3.3/API/Programming-Data-Subscription.md b/src/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
index 4c0b6730..1c996e3c 100644
--- a/src/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
+++ b/src/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
public class DataConsumerExample {
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
- try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+ try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
// 1. open session
session.open();
@@ -114,7 +114,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- // 2. Specify the consumption type as the tsfile type
- consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
diff --git a/src/UserGuide/dev-1.3/API/Programming-Data-Subscription.md b/src/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
index 4c0b6730..1c996e3c 100644
--- a/src/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
+++ b/src/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
public class DataConsumerExample {
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
- try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+ try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
// 1. open session
session.open();
@@ -114,7 +114,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- // 2. Specify the consumption type as the tsfile type
- consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
diff --git a/src/UserGuide/latest/API/Programming-Data-Subscription.md b/src/UserGuide/latest/API/Programming-Data-Subscription.md
index 4c0b6730..9391c04a 100644
--- a/src/UserGuide/latest/API/Programming-Data-Subscription.md
+++ b/src/UserGuide/latest/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
public class DataConsumerExample {
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
- try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+ try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
// 1. open session
session.open();
@@ -114,7 +114,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
pullConsumer.subscribe("topic_all");
@@ -161,7 +162,8 @@ public class DataConsumerExample {
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
// 2. Specify the consumption type as the tsfile type
- consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
diff --git a/src/zh/UserGuide/Master/Tree/API/Programming-Data-Subscription.md b/src/zh/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
index fe8896cd..2e387bd8 100644
--- a/src/zh/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
+++ b/src/zh/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
public class DataConsumerExample {
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
- try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+ try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
// 1. open session
session.open();
@@ -114,7 +114,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- // 2. Specify the consumption type as the tsfile type
- consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
diff --git a/src/zh/UserGuide/V1.3.3/API/Programming-Data-Subscription.md b/src/zh/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
index fe8896cd..2e387bd8 100644
--- a/src/zh/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
+++ b/src/zh/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
public class DataConsumerExample {
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
- try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+ try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
// 1. open session
session.open();
@@ -114,7 +114,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- // 2. Specify the consumption type as the tsfile type
- consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
diff --git a/src/zh/UserGuide/dev-1.3/API/Programming-Data-Subscription.md b/src/zh/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
index fe8896cd..2e387bd8 100644
--- a/src/zh/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
+++ b/src/zh/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
public class DataConsumerExample {
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
- try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+ try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
// 1. open session
session.open();
@@ -114,7 +114,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- // 2. Specify the consumption type as the tsfile type
- consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
diff --git a/src/zh/UserGuide/latest/API/Programming-Data-Subscription.md b/src/zh/UserGuide/latest/API/Programming-Data-Subscription.md
index fe8896cd..2e387bd8 100644
--- a/src/zh/UserGuide/latest/API/Programming-Data-Subscription.md
+++ b/src/zh/UserGuide/latest/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
public class DataConsumerExample {
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
- try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+ try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
// 1. open session
session.open();
@@ -114,7 +114,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
- // 2. Specify the consumption type as the tsfile type
- consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+ consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+ consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
pullConsumer.open();