最終回：SFDCのデータを抽出してAWSのS3にCSVを出力する(その4)

- 3月 12, 2020

このシリーズいよいよ最終回です。今回は前回のクラス群をまとめて、そいつをバッチ化するところをやっていきます。これでひとまず、SFDCに登録されたデータをSOQLで抽出してS3にCSVとしてアップロードということができました。ひとまずはやりたいことができたので一安心です。
(開発者エディションでやったので本番アップロード手順は知らない。)

◆大枠の手順

1.AWSでS3を設定する
　1)S3バケット作成
　2)IAMポリシー設定
　3)IAMユーザ追加
2.SFDC設定
　1)環境変数関連設定
　2)パラメータ入力
　3)リモートサイト許可
3.プログラム作成(単体レベル)
　1)環境変数抽出
　2)SOQLを使用してデータ抽出
　3)S3にCSVファイルをアップロード
4.バッチ設定

◆プログラム群

CsvSendController
--------------------

global class CsvSendController implements Schedulable,Database.AllowsCallouts{
   public void execute(SchedulableContext sc) {
       main();
   }
   //メール送信
   public void doSendMail(String subject,String body) {
        Messaging.SingleEmailMessage email = new Messaging.SingleEmailMessage();
        email.setToAddresses(new String[] { 'Mailaddr@example.com' });
        email.setSubject(subject);
        email.setPlainTextBody(body);
        List results = 
            Messaging.sendEmail(new Messaging.Email[] { email }, false);
        if (!results.get(0).isSuccess()) {
            System.StatusCode statusCode = results.get(0).getErrors()[0].getStatusCode();
            String errorMessage = results.get(0).getErrors()[0].getMessage();
        }    
   } 
  //主処理
  public void main(){
      String AccessKeyId;
      String SecretAccessKey;
      String BucketName;
      String Domain;
      try{
          //S3の設定値取得
          Map S3Param = new Map();
          GetEnvironment ge = new GetEnvironment();
          S3Param = ge.GetEnv();
          for(String sKey:S3Param.keySet()){
               if(sKey == 'S3Key'){
                 AccessKeyId = S3Param.get(sKey);
               }
               if(sKey == 'S3Token'){
                 SecretAccessKey = S3Param.get(sKey);
               }
               if(sKey == 'S3Bucket'){
                 BucketName = S3Param.get(sKey);
               }
               if(sKey == 'S3Domain'){
                 Domain = S3Param.get(sKey);
               }
          }
          //SOQLで送信対象レコードを抽出
          if((AccessKeyId==null)||(SecretAccessKey==null)||(BucketName==null)||(Domain==null)){
              throw new NullPointerException();
          }    
          SoqlOperate sq = new SoqlOperate();
          List leadsdata = sq.GetLeads();
          if(!leadsdata.isEmpty()){
              String body = sq.RecordsTransferCsv(leadsdata);
              List ids = sq.ReturnKeyId(leadsdata);
              //S3にファイル送信
              if(body==null){
                  throw new NullPointerException();
              }    
              String pfx =Datetime.now().format('yyyyMMddHHmmss');
              String fn = pfx + '_sample.csv';
              PutFiletoS3.PutS3(body,fn,AccessKeyId,SecretAccessKey,BucketName,Domain,ids);
              //処理完了時メール送信
              doSendMail('Complete','File Send Complete!');
          }else{
           System.debug('Processing target was 0');
          }
      }catch(Exception e){
          System.debug('Exception caught: ' + e.getMessage());
          system.debug(e.getLineNumber());
          String error = 'Exception caught: ' + e.getMessage() + '\r\n' + e.getLineNumber();
          doSendMail('Exception',error);
      }
  }
}

--------------------
CSVSendControllerTest
--------------------

@isTest(SeeAllData=true)
private class CSVSendControllerTest {
 @isTest static void doSendMail(){
        CsvSendController cs = new CsvSendController();
  String subject = 'This is subject';
        String body = 'This is Body!!';
  cs.doSendMail(subject,body);
    }
    @isTest static void mainTest(){
        CsvSendController cs = new CsvSendController();
  cs.main();
    }
}

--------------------
以下のコードをデバッグ登録
--------------------

//スケジューラ登録
CsvSendController cs = new CsvSendController();
//10分ごとのジョブ名指定
List sch = new List {
    '0 0 * * * ?','0 10 * * * ?','0 20 * * * ?',
    '0 30 * * * ?','0 40 * * * ?','0 50 * * * ?'
};
List Jobname = new List {
    'CsvSendController_00','CsvSendController_10','CsvSendController_20',
    'CsvSendController_30','CsvSendController_40','CsvSendController_50'
};
//スケジュール設定
for (Integer i = 0; i < 6 ; i++) {
     System.schedule(Jobname[i], sch[i] , cs);
}

--------------------

◆その他補足

1.デバッガを開く方法

2.スケジューラ登録状況

◆参考サイト

しょせん素人なので結局は以下のコピペです。
まぁもっとツヨツヨな方が色々と書かれているのでそちらを参考にされた方がいいかとは思います。SFDCのapexはよくわかりませんでしたが何とかなりました。
先人の皆様ありがとうございます。
＊但しもう二度と触りたくない、、、、

1.時刻を指定してSOQLでデータ抽出

　https://tyoshikawa1106.hatenablog.com/entry/2019/09/19/075843

2.S3(環境変数にS3のアクセスキー埋め込んで接続してCSV出力)

　http://kayakuguri.github.io/blog/2017/04/10/put-s3-csv-file/

　https://kayakuguri.github.io/blog/2016/02/01/custom-setting/

3.スケジューラ設定

　https://qiita.com/naoto_koyama/items/83624f70e29dfa7067eb

このブログを検索

アラフィフおやじログ