Útmutató az NIFI ConsumePOP3 konfigurálásához Outlook 365-höz

NIFI ConsumePOP3 processzor konfigurálása az Outlook 365-höz

NIFI processzor konfigurációs parancsfájl

import org.apache.nifi.processor.AbstractProcessor;
import org.apache.nifi.processor.ProcessorInitializationContext;
import org.apache.nifi.processor.Relationship;
import org.apache.nifi.components.PropertyDescriptor;
import org.apache.nifi.annotation.lifecycle.OnScheduled;
import org.apache.nifi.annotation.lifecycle.OnUnscheduled;
import java.util.Set;
import java.util.HashSet;
import javax.mail.Session;
import javax.mail.Store;
public class ConsumePOP3Outlook365 extends AbstractProcessor {
    public static final PropertyDescriptor EMAIL_ADDRESS = new PropertyDescriptor.Builder()
        .name("Email Address")
        .description("Outlook 365 email address")
        .required(true)
        .addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
        .build();
    public static final PropertyDescriptor EMAIL_PASSWORD = new PropertyDescriptor.Builder()
        .name("Email Password")
        .description("App password generated from Outlook 365 account")
        .required(true)
        .addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
        .sensitive(true)
        .build();
    private static final Set<Relationship> relationships = new HashSet<>();
    @Override
    protected void init(final ProcessorInitializationContext context) {
        relationships.add(new Relationship.Builder()
            .name("success")
            .description("Successful retrieval of emails")
            .build());
        relationships.add(new Relationship.Builder()
            .name("failure")
            .description("Failed retrieval of emails")
            .build());
    }
    @OnScheduled
    public void onScheduled(final ProcessContext context) {
        // Logic to connect to Outlook 365 using POP3
        Properties props = new Properties();
        props.put("mail.store.protocol", "pop3s");
        props.put("mail.pop3s.host", "outlook.office365.com");
        props.put("mail.pop3s.port", "995");
        Session session = Session.getDefaultInstance(props);
        try {
            Store store = session.getStore("pop3s");
            store.connect(context.getProperty(EMAIL_ADDRESS).getValue(),
                          context.getProperty(EMAIL_PASSWORD).getValue());
            // Add logic to retrieve and process emails
        } catch (Exception e) {
            getLogger().error("Failed to connect to Outlook 365", e);
        }
    }
}

Python Script az Outlook 365 e-mailek csatlakozásához és lekéréséhez POP3 használatával

Python szkript az e-mailek lekéréséhez

import poplib
from email import parser
POP3_SERVER = 'outlook.office365.com'
POP3_PORT = 995
EMAIL = 'your-email@outlook.com'
PASSWORD = 'your-app-password'
def get_emails():
    server = poplib.POP3_SSL(POP3_SERVER, POP3_PORT)
    server.user(EMAIL)
    server.pass_(PASSWORD)
    messages = [server.retr(i) for i in range(1, len(server.list()[1]) + 1)]
    messages = [b"\n".join(mssg[1]).decode('utf-8') for mssg in messages]
    messages = [parser.Parser().parsestr(mssg) for mssg in messages]
    for message in messages:
        print('From: %s' % message['from'])
        print('Subject: %s' % message['subject'])
        print('Body: %s' % message.get_payload())
    server.quit()
if __name__ == '__main__':
    get_emails()

Gyakori kérdések és megoldások az NIFI ConsumePOP3 konfigurációhoz

1. Melyek a megfelelő kiszolgálóbeállítások az Outlook 365 számára?
2. A szervernek kell lennie outlook.office365.com a kikötő pedig legyen 995 biztonságos POP3 kapcsolatokhoz.
3. Hogyan engedélyezhetem a POP3 hozzáférést az Outlook 365-ben?
4. Lépjen az Office 365 felügyeleti központjába, lépjen a felhasználói beállításokhoz, és engedélyezze a POP3 hozzáférést.
5. Mi a teendő, ha hitelesítési hibát kapok?
6. Győződjön meg arról, hogy az Outlook 365-fiókból generált alkalmazásjelszót használja, nem pedig a szokásos jelszavát.
7. Használhatom ugyanazt az alkalmazásjelszót több eszközhöz?
8. Igen, egy alkalmazásjelszó több POP3-hozzáférésre konfigurált eszközön és alkalmazásban is használható.
9. Miért működik a kapcsolat a Gmailben, de az Outlook 365-ben nem?
10. Ennek oka lehet a kiszolgálóbeállítások, a portkonfigurációk eltérése, vagy a POP3 hozzáférés engedélyezése az Outlook 365-ben.
11. Mi a szerepe a PropertyDescriptor a NIFI processzor szkriptjében?
12. Meghatározza a processzor konfigurálható tulajdonságait, például e-mail címet és jelszót.
13. Hogyan lehet hibakeresni a csatlakozási problémákat?
14. Ellenőrizze a naplókban hibaüzeneteket, ellenőrizze a kiszolgáló beállításait, győződjön meg arról, hogy a POP3 engedélyezve van, és győződjön meg arról, hogy a megfelelő alkalmazásjelszót használja.
15. Mi a jelentősége a OnScheduled megjegyzés a NIFI szkriptben?
16. Biztosítja, hogy az e-mailek csatlakozásának és lekérésének módszere végrehajtásra kerüljön, amikor a processzor futni ütemezett.

Utolsó gondolatok a NIFI konfigurációról

Az NIFI ConsumePOP3 processzor Outlook 365-höz való sikeres konfigurálása bizonyos részleteket igényel, például a kiszolgálóbeállításokat és a POP3 hozzáférés engedélyezését. A Java és Python által biztosított szkriptek robusztus megoldást kínálnak az üzenetek csatlakoztatására és lekérésére. A megfelelő alkalmazásjelszó használatának biztosításával és a konfigurációk ellenőrzésével a felhasználók leküzdhetik a gyakori akadályokat. Ez az útmutató átfogó forrásként szolgál a hibaelhárításhoz és a processzor beállításához, biztosítva az Outlook 365-tel való zökkenőmentes integrációt az e-mailek lekéréséhez.