Динамический FTP Папка конвейера

Question

Динамический FTP Папка конвейера

Я пытаюсь динамически установить выходную папку FTP-местоположения. Назначение, для каждого клиента мне нужно создать отдельную папку для хранения файла Excel и / или файла XML.

Что я пробовал

Создан пользовательский компонент конвейера, чтобы установить все необходимые свойства в порт отправки FTP.
Пробовал тот же конвейер в динамический порт отправки
Для тестирования попробовал код в оркестровке.

Что я заметил:

Когда я отправляю через порт отправки FTP, свойства не будут переопределены пользовательскими свойствами конвейера.

Когда я отправляю через Dynamic, я всегда получаю следующую ошибку

При передаче сообщения произошла ошибка

Даже когда я пытаюсь установить свойства в Orchestration, я получаю ту же ошибку.

Также, когда я пытаюсь отправить через динамический порт отправки, я замечаю, что компонент конвейера не затрагивается.

Выполнить часть кода пользовательского компонента конвейера

public IBaseMessage Execute(IPipelineContext pipelineContext, IBaseMessage inputMessage)
    {
        Guid callToken = TraceManager.PipelineComponent.TraceIn(CLASSNAME + ".Execute() - Start", pipelineContext.PipelineID, pipelineContext.PipelineName, pipelineContext.StageID);

        if (!this.Active)
        {
            TraceManager.PipelineComponent.TraceOut(callToken, CLASSNAME + ".Execute() - Pipeline component is not active!");
            return inputMessage;
        }

        try
        {
            string completeFTPUri = null;
            string fileName = null;
            string accountNumber = Convert.ToString(inputMessage.Context.Read(PROP_ACCOUNTNUMBER.Name.Name, PROP_ACCOUNTNUMBER.Name.Namespace));

            if (!string.IsNullOrWhiteSpace(accountNumber))
                this.Folder = string.Format("{0}/{1}", this.Folder, accountNumber);

            if (!string.IsNullOrWhiteSpace(this.Folder))
                completeFTPUri = string.Format("ftp://{0}:21/{1}", this.FTPUri, this.Folder);
            else
                completeFTPUri = this.FTPUri;

            if (!UseDefaultFilename)
            {
                string receiveFilename = null;
                receiveFilename = Convert.ToString(inputMessage.Context.Read(FTP_RECEIVED_FILENAME.Name.Name, FTP_RECEIVED_FILENAME.Name.Namespace));

                if (!string.IsNullOrWhiteSpace(receiveFilename))
                    fileName = Path.GetFileName(receiveFilename);
            }

            if (string.IsNullOrWhiteSpace(fileName))
            {
                if (string.IsNullOrWhiteSpace(this.Filename))
                    fileName = DEFAULT_FILENAME;
                else
                    fileName = this.Filename;
            }

            if (fileName.Contains("{0") || fileName.Contains("{1"))
            {
                fileName = string.Format(fileName, DateTime.Now, inputMessage.MessageID);
            }

            if (!string.IsNullOrWhiteSpace(this.Folder))
            {
                //inputMessage.Context.Write(FTP_BEFORE_PUT.Name.Name, FTP_BEFORE_PUT.Name.Namespace, string.Format("MKDIR {0}", string.Format("ftp://{0}:21/{1}", this.FTPUri, this.Folder)));
                inputMessage.Context.Promote(FTP_BEFORE_PUT.Name.Name, FTP_BEFORE_PUT.Name.Namespace, string.Format("MKDIR {0}", completeFTPUri));
            }

            //inputMessage.Context.Write(OUTBOUND_TRANSPORT_LOCATION.Name.Name, OUTBOUND_TRANSPORT_LOCATION.Name.Namespace, completeFTPUri);
            //inputMessage.Context.Write(FILE_RECEIVED_FILENAME.Name.Name, FILE_RECEIVED_FILENAME.Name.Namespace, fileName);
            //inputMessage.Context.Write(FTP_USERNAME.Name.Name, FTP_USERNAME.Name.Namespace, _userName);
            //inputMessage.Context.Write(FTP_PASSWORD.Name.Name, FTP_PASSWORD.Name.Namespace, _password);
            inputMessage.Context.Promote(OUTBOUND_TRANSPORT_LOCATION.Name.Name, OUTBOUND_TRANSPORT_LOCATION.Name.Namespace, completeFTPUri);
            inputMessage.Context.Promote(OUTBOUND_TRANSPORT_TYPE.Name.Name, OUTBOUND_TRANSPORT_TYPE.Name.Namespace, "FTP");
            inputMessage.Context.Promote(FILE_RECEIVED_FILENAME.Name.Name, FILE_RECEIVED_FILENAME.Name.Namespace, fileName);
            inputMessage.Context.Promote(FTP_USERNAME.Name.Name, FTP_USERNAME.Name.Namespace, this.UserName);
            inputMessage.Context.Promote(FTP_PASSWORD.Name.Name, FTP_PASSWORD.Name.Namespace, this.Password);

        }
        catch (Exception ex)
        {
            TraceManager.PipelineComponent.TraceError(ex, false, callToken);
            throw new Exception(CLASSNAME + ".Execute() - Failed to set the filename.", ex);
        }

        TraceManager.PipelineComponent.TraceOut(callToken, CLASSNAME + ".Execute() - Finished.");
        return inputMessage;
    }

РЕДАКТИРОВАТЬ:

После много попыток это обновление обновляет. Когда я пытаюсь отправить динамически через статический SendPort, я сохраняю ту же проблему. Когда я пытаюсь отправить динамически через динамический SendPort, я получаю другую ошибку:

Внутреннее исключение: значение, присвоенное свойству "Microsoft.XLANGs.BaseTypes.Address", недопустимо: "FTP URI".

Я не знаю, как лучше всего решить эту проблему. Я также могу написать все во вспомогательный класс и попытаться отправить через код C#. Но я хочу использовать силу BizTalk и хочу иметь возможность включать и отключать порты при необходимости. Это главная причина. Я не боюсь писать собственные компоненты конвейера или что-то еще, так что если кто-то может помочь. ПОЖАЛУЙСТА

Код сообщения о присвоении оркестровки

MsgPublishArticleMessage = MsgFullArticleMessage;
MsgPublishArticleMessage(*) = MsgFullArticleMessage(*);

MsgPublishArticleMessage(DOMAIN.BizTalk.Common.Schemas.Domain) = "ArticleMessage";
MsgPublishArticleMessage(DOMAIN.BizTalk.Common.Schemas.Service) = "PricatService";
MsgPublishArticleMessage(DOMAIN.BizTalk.Common.Schemas.Action) = "PublishPricatXLSX";
MsgPublishArticleMessage(DOMAIN.BizTalk.Common.Schemas.Version) = "1.0";
MsgPublishArticleMessage(DOMAIN.BizTalk.Common.Schemas.AccountNumber) = articleMessageRequest.AccountNumber;
MsgPublishArticleMessage(BTS.OutboundTransportLocation) = "ftp://URI:21/Pricat/" + articleMessageRequest.AccountNumber;
MsgPublishArticleMessage(BTS.OutboundTransportType) = "FTP";
MsgPublishArticleMessage(FTP.Password) = "********";
MsgPublishArticleMessage(FTP.UserName) = "UserName";
MsgPublishArticleMessage(FTP.BeforePut) = "MKDIR " + articleMessageRequest.AccountNumber;
MsgPublishArticleMessage(FTP.ReceivedFileName) = Destil.BizTalk.ArticleMessage.Components.OrchestrationHelper.CreateReceivedFileName(articleMessageRequest, ".xlsx");
PublishArticleMessagePort(Microsoft.XLANGs.BaseTypes.Address) = "FTPURI";
PublishArticleMessagePort(Microsoft.XLANGs.BaseTypes.TransportType) = "FTP";
MsgPublishArticleMessage(BTS.IsDynamicSend) = true;

РЕДАКТИРОВАТЬ 2:

Когда я изменяю Назначение сообщений на приведенный ниже код, я могу отправить файл в динамическую папку. Единственная проблема, с которой я сталкиваюсь сейчас: когда папка уже существует, я получаю сбой.

Кто-нибудь знает, какую команду FTP мне нужно использовать для создания папки, только если она не существует? Я попробовал следующие команды

MDK -p / Pricat / AccountNumber;
MDK / Pricat / AccountNumber;
если не существует "/Pricat/AccountNumber" MDK /Pricat/AccountNumber

Изменен код присвоения сообщения в оркестровке

MsgPublishArticleMessage = MsgFullArticleMessage;
MsgPublishArticleMessage(*) = MsgFullArticleMessage(*);

MsgPublishArticleMessage(DOMAIN.BizTalk.Common.Schemas.Domain) = "ArticleMessage";
MsgPublishArticleMessage(DOMAIN.BizTalk.Common.Schemas.Service) = "PricatService";
MsgPublishArticleMessage(DOMAIN.BizTalk.Common.Schemas.Action) = "PublishPricatXLSX";
MsgPublishArticleMessage(DOMAIN.BizTalk.Common.Schemas.Version) = "1.0";
MsgPublishArticleMessage(DOMAIN.BizTalk.Common.Schemas.AccountNumber) = articleMessageRequest.AccountNumber;
MsgPublishArticleMessage(BTS.OutboundTransportLocation) = "ftp://URI:21/Pricat/" + articleMessageRequest.AccountNumber;
MsgPublishArticleMessage(BTS.OutboundTransportType) = "FTP";
MsgPublishArticleMessage(FTP.Password) = "*********";
MsgPublishArticleMessage(FTP.UserName) = "username";
MsgPublishArticleMessage(FTP.BeforePut) = "MKD Pricat/" + articleMessageRequest.AccountNumber + "; CWD Pricat/" + articleMessageRequest.AccountNumber;
PublishArticleMessagePort(Microsoft.XLANGs.BaseTypes.Address) = "ftp://URI:21/" + DOMAIN.BizTalk.ArticleMessage.Components.OrchestrationHelper.CreateReceivedFileName(articleMessageRequest, ".xlsx");
PublishArticleMessagePort(Microsoft.XLANGs.BaseTypes.TransportType) = "FTP";
MsgPublishArticleMessage(BTS.IsDynamicSend) = true;

1

biztalk biztalk-2016 custom-pipeline-component send-port

Источник

user7755242 07 мар '18 в 13:39

2 ответа

Другие вопросы по тегам biztalk biztalk-2016 custom-pipeline-component send-port

user4009097 09 мар '18 в 00:24 2018-03-09 00:24 · Answer 1 · 2018-03-09 00:24

Из предоставленного вами фрагмента кода вы можете проверить следующую строку.

PublishArticleMessagePort(Microsoft.XLANGs.BaseTypes.Address) = "FTPURI";

Вы объявили FTPURI как переменную и присвоили адресу постоянную строку. Это может объяснить ошибку -

Внутреннее исключение: значение, присвоенное свойству "Microsoft.XLANGs.BaseTypes.Address", недопустимо: "FTP URI".

user4407856 08 мар '18 в 08:54 2018-03-08 08:54 · Answer 2 · 2018-03-08 08:54

При перезаписи статических свойств порта отправки вы должны сообщить адаптеру, что он должен использовать свойства сообщения вместо свойств порта.

Установите для свойства IsDynamicSend значение true

inmsg.Context.Promote("IsDynamicSend", "http://schemas.microsoft.com/BizTalk/2003/system-properties", true);

0

Источник

user4407856 08 мар '18 в 08:54