Code que j ai fait

#include <ESP8266wifi.h>
#include <SoftwareSerial.h>
#include <WiFi.h>
#include <WiFiClient.h>
#include <WiFiServer.h>
#include <WiFiUdp.h>
#include <PubSubClient.h>

// WiFi credentials
const char* ssid = "........";
const char* password = ".........";

// AWS IoT Core endpoint and credentials
const char* awsEndpoint = ".............";
const int awsPort = 8883;
const char* awsClientId = "............";
const char* awsUsername = ".............";
const char* awsPrivateKey =
const char* awsCertificate = "
// MQTT topics
const char* topicCapteur1 = "votre-topic-capteur1";
const char* topicCapteur2 = "votre-topic-capteur2";

WiFiClient wifiClient;
PubSubClient mqttClient(wifiClient);

int ledRouge = 12;
int ledVert = 13;
int boutonPomper = 3;
int boutonTurbinage = 4;

void setup() {
pinMode(ledRouge, OUTPUT);
pinMode(ledVert, OUTPUT);
pinMode(boutonPomper, INPUT);
pinMode(boutonTurbinage, INPUT);
Serial.begin(9600);

connectToWiFi();
connectToAWS();
}

void loop() {
int capteur1 = analogRead(A0);
Serial.println(capteur1);
int capteur2 = analogRead(A1);
Serial.println(capteur2);
if (capteur1 > 10) {
digitalWrite(ledVert, HIGH);
} else {
delay(3000);
digitalWrite(ledVert, LOW);
}

if (capteur2 > 10) {
digitalWrite(ledRouge, HIGH);
if (capteur1 > 10) {
digitalWrite(ledRouge, LOW);
}
}

if (capteur1 < 10 && capteur2 < 10) {
digitalWrite(ledVert, LOW);
digitalWrite(ledRouge, LOW);
}

publishData("capteur1", String(capteur1));
publishData("capteur2", String(capteur2));

mqttClient.loop();
}

void connectToWiFi() {
Serial.println("Connecting to WiFi...");
WiFi.begin(ssid, password);

while (WiFi.status() != WL_CONNECTED) {
delay(1000);
Serial.print(".");
}

Serial.println("");
Serial.println("WiFi connected");
Serial.print("IP address: ");
Serial.println(WiFi.localIP());
}

void connectToAWS() {
Serial.println("Connecting to AWS IoT Core...");
mqttClient.setServer(awsEndpoint, awsPort);
mqttClient.setCallback(callback);

while (!mqttClient.connected()) {
if (mqttClient.connect(awsClientId)) {
Serial.println("AWS IoT Core connected");
mqttClient.subscribe(topicCapteur1);
mqttClient.subscribe(topicCapteur2);
} else {
Serial.print("Failed, rc=");
Serial.print(mqttClient.state());
Serial.println(" Retrying in 5 seconds...");
delay(5000);
}
}
}

void callback(char* topic, byte* payload, unsigned int length) {
Serial.print("Message received on topic: ");
Serial.println(topic);

String message = "";
for (int i = 0; i < length; i++) {
message += (char)payload[i];
}

Serial.print("Message received: ");
Serial.println(message);
}

void publishData(const char* topic, String data) {
char charData[data.length() + 1];
data.toCharArray(charData, sizeof(charData));

mqttClient.publish(topic, charData);
Serial.print("Published data: ");
Serial.println(data);
}

Pas de doublon merci
Topic verrouillé, les échanges continues ici