Посібник із налаштування NIFI ConsumePOP3 для Outlook 365

Налаштування процесора NIFI ConsumePOP3 для Outlook 365

Сценарій конфігурації процесора NIFI

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 для підключення та отримання електронних листів з Outlook 365 за допомогою POP3

Сценарій Python для отримання електронної пошти

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()

Поширені запитання та рішення щодо конфігурації NIFI ConsumePOP3

1. Які правильні параметри сервера для Outlook 365?
2. Сервер повинен бути outlook.office365.com і порт повинен бути 995 для безпечних з’єднань POP3.
3. Як увімкнути доступ POP3 в Outlook 365?
4. Перейдіть до центру адміністрування Office 365, перейдіть до налаштувань користувача та ввімкніть доступ POP3.
5. Що робити, якщо я отримую помилку автентифікації?
6. Переконайтеся, що ви використовуєте пароль програми, створений з облікового запису Outlook 365, а не звичайний пароль.
7. Чи можу я використовувати той самий пароль програми для кількох пристроїв?
8. Так, пароль програми можна використовувати на кількох пристроях і програмах, налаштованих для доступу POP3.
9. Чому підключення працює для Gmail, але не для Outlook 365?
10. Це може бути пов’язано з відмінностями в налаштуваннях сервера, конфігураціях портів або через необхідність увімкнути доступ POP3 саме в Outlook 365.
11. Яка роль PropertyDescriptor у сценарії процесора NIFI?
12. Він визначає конфігуровані властивості для процесора, такі як адреса електронної пошти та пароль.
13. Як я можу усунути проблеми з підключенням?
14. Перевірте журнали на наявність повідомлень про помилки, перевірте налаштування сервера, переконайтеся, що POP3 увімкнено, і підтвердьте, що ви використовуєте правильний пароль програми.
15. Яке значення має OnScheduled анотація в сценарії NIFI?
16. Це гарантує, що метод підключення та отримання електронних листів виконується, коли заплановано роботу процесора.

Останні думки щодо конфігурації NIFI

Успішне налаштування процесора NIFI ConsumePOP3 для Outlook 365 вимагає уваги до певних деталей, таких як налаштування сервера та ввімкнення доступу POP3. Надані сценарії на Java та Python пропонують надійне рішення для підключення та отримання повідомлень. Забезпечивши використання правильного пароля програми та перевіривши конфігурації, користувачі можуть подолати типові перешкоди. Цей посібник є вичерпним ресурсом для усунення несправностей і налаштування процесора, забезпечуючи повну інтеграцію з Outlook 365 для отримання електронної пошти.