Outlook 365 用の NIFI ConsumePOP3 の構成ガイド

Outlook 365 用の NIFI ConsumePOP3 プロセッサの構成

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);
        }
    }
}

POP3 を使用して Outlook 365 に接続して電子メールを取得するための Python スクリプト

電子メール取得用の 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. Outlook 365 で POP3 アクセスを有効にするにはどうすればよいですか?
4. Office 365 管理センターに移動し、ユーザーの設定に移動して、POP3 アクセスを有効にします。
5. 認証エラーが発生した場合はどうすればよいですか?
6. 通常のパスワードではなく、Outlook 365 アカウントから生成されたアプリ パスワードを使用していることを確認してください。
7. 複数のデバイスで同じアプリ パスワードを使用できますか?
8. はい、アプリ パスワードは、POP3 アクセス用に構成された複数のデバイスおよびアプリケーション間で使用できます。
9. Gmail では接続できるのに、Outlook 365 では接続できないのはなぜですか?
10. これは、サーバー設定、ポート構成の違い、または特に Outlook 365 で POP3 アクセスを有効にする必要性が原因である可能性があります。
11. の役割は何ですか PropertyDescriptor NIFIプロセッサスクリプト内で?
12. 電子メール アドレスやパスワードなど、プロセッサの構成可能なプロパティを定義します。
13. 接続の問題をデバッグするにはどうすればよいですか?
14. ログでエラー メッセージを確認し、サーバー設定を確認し、POP3 が有効になっていることを確認し、正しいアプリ パスワードを使用していることを確認します。
15. の重要性は何ですか OnScheduled NIFI スクリプトの注釈?
16. これにより、プロセッサの実行がスケジュールされているときに、電子メールに接続して取得するメソッドが確実に実行されます。

NIFI 構成に関する最終的な考え

Outlook 365 用に NIFI ConsumePOP3 プロセッサを正常に構成するには、サーバー設定や POP3 アクセスの有効化などの特定の詳細に注意する必要があります。 Java および Python で提供されるスクリプトは、メッセージを接続して取得するための堅牢なソリューションを提供します。正しいアプリのパスワードを使用し、構成を確認することで、ユーザーは一般的な障害を克服できます。このガイドは、プロセッサのトラブルシューティングとセットアップのための包括的なリソースとして機能し、電子メールの取得のために Outlook 365 とのシームレスな統合を保証します。