Comment importer des données Microsoft Exchange vers SQL dans SSIS

Question

Mon chef m'a donné un travail pour réécrire un vieux morceau de logiciel dans un paquet SSIS. J'ai besoin SSIS:

• accèdent à une boîte aux lettres spécifique sur notre serveur Microsoft Exchange
• passer par tous les e-mails non lus et télécharger des pièces jointes d'eux en fonction de leur type de fichier
• importer le contenu de ces fichiers (texte lisible par bloc-notes) dans une table SQL
• sujets e-mail à l'importation à une autre table SQL

Je ne sais pas si ce que je décrit ci-dessus est disponible dans un paquet standard SSIS (je doute il) - peut-être que je devrais télécharger quelques bibliothèques. Jusqu'à présent, j'ai trouvé this. Est-ce que ça va faire l'affaire? Si non, connaissez-vous un autre moyen de réaliser ce que je veux en utilisant SSIS?

Answer 1

Il se trouve que la bibliothèque par défaut SSIS ne possède pas les éléments nécessaires pour établir une connexion à un serveur Exchange. J'ai trouvé 2 bibliothèques de tiers qui vous permettent de le faire:

• CozyRoc
• CData

Les deux d'entre eux sont payés, mais aussi des versions d'essai gratuites.

Answer 2

Le meilleur moyen serait d'utiliser le Microsoft Exchange Webservices (= EWS) pour télécharger et work with all kind of attachments (ici est un example).

Toutefois, comme il s'agit d'une API, vous devez créer une sorte de middleware entre MS Exchange et votre serveur SQL Server en fonction du code EWS API. Il pourrait être quelque chose comme:

//TODO: Replace these with your values 
NetworkCredential exchangeAccessAccount = new NetworkCredential(@"UserName", @"Password", @"Domain"); 
Uri OutlookWebAccessUri = new Uri(@"[[Outlook Web Access Url]]/EWS/Exchange.asmx"); 
DateTime CalanderStart = new DateTime(); 
DateTime CalanderEnd = new DateTime(); 
int MaxItemsToReturn = 99999; 

try 
{ 
    #region create service binding 

    // Create the service binding. 
    ExchangeService esb = new ExchangeService(ExchangeVersion.Exchange2007_SP1); 
    esb.Credentials = exchangeAccessAccount; 
    esb.Url = OutlookWebAccessUri; 
    esb.ImpersonatedUserId = new ImpersonatedUserId(ConnectingIdType.PrincipalName, Variables.UserDomainID.ToString()); 

    #endregion 

    #region create CalendarView 

    CalendarView calendarView = new CalendarView(CalanderStart, CalanderEnd, MaxItemsToReturn); 
    calendarView.PropertySet = PropertySet.IdOnly; 

    #endregion 

    #region retrieve responce 

    // Do the EWS Call... 
    FindItemsResults<Appointment> findItemResponse = esb.FindAppointments(WellKnownFolderName.Calendar, calendarView); 

    if (findItemResponse == null) 
    { 
     return; 
    } 

    #endregion 

    #region load atendee data 

    //get additional properties for each item returned by view, do this as view cannot return a lot of useful stuff like attendees 
    ServiceResponseCollection<ServiceResponse> addProperties = 
       esb.LoadPropertiesForItems(from Item item in findItemResponse select item, 
       new PropertySet(
         BasePropertySet.IdOnly, 
         AppointmentSchema.Resources, 
         AppointmentSchema.RequiredAttendees, 
         AppointmentSchema.OptionalAttendees, 
         AppointmentSchema.Subject, 
         AppointmentSchema.Start, 
         AppointmentSchema.End, 
         AppointmentSchema.IsCancelled 
         )); 

    List<Appointment> additionalProperties = new List<Appointment>(addProperties.Count); 

    if (addProperties != null) 
    { 
     foreach (ServiceResponse currentResponce in addProperties) 
     { 
      additionalProperties.Add(((Appointment)((GetItemResponse)currentResponce).Item)); 
     } 
    } 

    #endregion 

    #region process appts 

    Appointment currentAppointmentAddProps = null; 

    foreach (Appointment currentAppointment in findItemResponse) 
    { 
     #region find additional properties for current Appointment 

     currentAppointmentAddProps = additionalProperties.Find(delegate(Appointment arg) 
       { return arg.Id == currentAppointment.Id; }); 

     #endregion 

     //add data to output here 
     OutputRecordSetBuffer.ActualEndDate = currentAppointmentAddProps.End; 

    } 

    #endregion 
} 
catch (Exception e) 
{ 

} 

(plus d'infos here)