워크플로에서 OData 피드 사용
WCF Data Services는 REST(Representational State Transfer)의 의미 체계를 사용하여 웹 또는 인트라넷을 통해 데이터를 노출하고 사용하기 위해 Open Data Protocol(OData)을 사용하는 서비스를 만들 수 있도록 하는 .NET Framework의 구성 요소입니다. OData는 URI로 주소를 지정할 수 있는 리소스로 데이터를 노출합니다. HTTP 요청을 보내고 데이터 서비스에서 반환하는 OData 피드를 처리할 수 있는 애플리케이션은 모두 OData 기반 데이터 서비스와 상호 작용할 수 있습니다. 또한 WCF Data Services에는 .NET Framework 애플리케이션에서 OData 피드를 사용할 때 보다 다양한 기능을 갖춘 프로그래밍 환경을 제공하는 클라이언트 라이브러리가 포함되어 있습니다. 이 항목에서는 클라이언트 라이브러리를 사용하거나 사용하지 않고 워크플로에서 OData 피드를 사용하는 방법에 대해 간략하게 설명합니다.
샘플 Northwind OData 서비스 사용
이 항목의 예제에서는 https://services.odata.org/Northwind/Northwind.svc/에 있는 샘플 Northwind 데이터 서비스를 사용합니다. 이 서비스는 OData SDK 의 일부로 제공되며 샘플 Northwind 데이터베이스에 읽기 전용으로 액세스할 수 있게 해줍니다. 쓰기 권한이 필요하거나 로컬 WCF 데이터 서비스가 필요한 경우 퀵 스타트(WCF Data Services) 의 단계를 수행하여 Northwind 데이터베이스에 액세스할 수 있게 해 주는 로컬 OData 서비스를 만들 수 있습니다. 퀵 스타트를 따르는 경우 이 항목의 예제 코드에 제공된 URI를 로컬 URI로 바꿉니다.
클라이언트 라이브러리를 사용하여 OData 피드 사용
WCF Data Services에는 .NET Framework 및 클라이언트 애플리케이션에서 OData 피드를 보다 쉽게 사용할 수 있도록 클라이언트 라이브러리가 포함되어 있습니다. 이러한 라이브러리는 HTTP 메시지를 보내고 받는 작업을 단순화합니다. 또한 엔터티 데이터를 나타내는 CLR 개체로 메시지 페이로드를 변환합니다. 클라이언트 라이브러리는 두 가지 핵심 클래스인 DataServiceContext 및 DataServiceQuery<TElement>를 제공합니다. 이러한 클래스를 사용하면 데이터 서비스를 쿼리한 다음 반환된 엔터티 데이터를 CLR 개체로 사용하여 작업할 수 있습니다. 이 단원에서는 클라이언트 라이브러리를 사용하는 활동을 만드는 두 가지 방법에 대해 설명합니다.
WCF Data Service에 서비스 참조 추가
Northwind 클라이언트 라이브러리를 생성하려면 Visual Studio 2012에서 서비스 참조 추가 대화 상자를 사용하여 Northwind OData 서비스에 참조를 추가할 수 있습니다.
서비스에서 노출하는 서비스 작업이 없으며 서비스 목록에 Northwind 데이터 서비스에서 노출하는 엔터티를 나타내는 항목이 있습니다. 서비스 참조가 추가되면 이러한 엔터티에 대한 클래스가 생성되며 클라이언트 코드에서 사용될 수 있습니다. 이 항목의 예제에서는 이러한 클래스와 NorthwindEntities 클래스를 사용하여 쿼리를 수행합니다.
참고 항목
자세한 내용은 데이터 서비스 클라이언트 라이브러리 생성(WCF Data Services)을 참조하세요.
비동기 메서드 사용
웹을 통해 리소스에 액세스할 때 발생할 수 있는 지연 문제를 해결하려면 WCF Data Services에 비동기적으로 액세스하는 것이 좋습니다. WCF Data Services 클라이언트 라이브러리는 쿼리를 호출하는 데 필요한 비동기 메서드를 포함하고 Windows WF(Workflow Foundation)는 권한 부여 비동기 동작에 필요한 AsyncCodeActivity 클래스를 제공합니다. AsyncCodeActivity 파생 동작은 비동기 메서드가 있는 .NET Framework 클래스를 사용하여 기록될 수 있거나, 비동기적으로 실행되는 코드는 메서드에 넣어 대리자를 사용하여 호출할 수 있습니다. 이 단원에서는 AsyncCodeActivity 파생 활동의 두 가지 예제를 제공합니다. 한 예제에서는 WCF Data Services 클라이언트 라이브러리의 비동기 메서드를 사용하고 다른 예제에서는 대리자를 사용합니다.
참고 항목
자세한 내용은 비동기 작업(WCF Data Services) 및 동기 활동 만들기를 참조하세요.
클라이언트 라이브러리 비동기 메서드 사용
DataServiceQuery<TElement> 클래스는 OData 서비스를 비동기적으로 쿼리하기 위한 BeginExecute 및 EndExecute 메서드를 제공합니다. 이러한 메서드는 BeginExecute 파생 클래스의 EndExecute 및 AsyncCodeActivity 재정의에서 호출할 수 있습니다. AsyncCodeActivity BeginExecute 재정의가 반환되면 워크플로가 유휴 상태가 될 수 있으며(그러나 유지되지는 않음), 비동기 작업이 완료되면 EndExecute는 런타임에서 호출됩니다.
다음 예제에서는 두 입력 인수를 가진 OrdersByCustomer 활동을 정의합니다. CustomerId 인수는 반환할 주문을 식별하는 고객을 나타내고, ServiceUri 인수는 쿼리할 OData 서비스의 URI를 나타냅니다. 활동이 AsyncCodeActivity<IEnumerable<Order>> 에서 파생되기 때문에 쿼리의 결과를 반환하는 데 사용되는 Result 출력 인수도 있습니다. BeginExecute 재정의는 지정된 고객의 모든 주문을 선택하는 LINQ 쿼리를 만듭니다. 이 쿼리는 전달된 UserState 의 AsyncCodeActivityContext로 지정되며, 그런 다음 쿼리의 BeginExecute 메서드가 호출됩니다. 쿼리의 BeginExecute 로 전달된 콜백과 상태는 활동의 BeginExecute 메서드에 전달되는 콜백과 상태입니다. 쿼리 실행이 완료되면 활동의 EndExecute 메서드가 호출됩니다. 쿼리는 UserState에서 검색되며, 그런 다음 쿼리의 EndExecute 메서드가 호출됩니다. 이 메서드는 지정된 엔터티 형식의 IEnumerable<T> 을 반환합니다. 이 경우에는 Order를 반환합니다. IEnumerable<Order>가 AsyncCodeActivity<TResult>의 제네릭 형식이므로 이 IEnumerable은 활동의 Result OutArgument<T>로 설정됩니다.
class OrdersByCustomer : AsyncCodeActivity<IEnumerable<Order>>
{
[RequiredArgument]
public InArgument<string> CustomerId { get; set; }
[RequiredArgument]
public InArgument<string> ServiceUri { get; set; }
protected override IAsyncResult BeginExecute(AsyncCodeActivityContext context, AsyncCallback callback, object state)
{
NorthwindEntities dataContext = new NorthwindEntities(new Uri(ServiceUri.Get(context)));
// Define a LINQ query that returns Orders and
// Order_Details for a specific customer.
DataServiceQuery<Order> ordersQuery = (DataServiceQuery<Order>)
from o in dataContext.Orders.Expand("Order_Details")
where o.Customer.CustomerID == CustomerId.Get(context)
select o;
// Specify the query as the UserState for the AsyncCodeActivityContext
context.UserState = ordersQuery;
// The callback and state used here are the ones passed into
// the BeginExecute of this activity.
return ordersQuery.BeginExecute(callback, state);
}
protected override IEnumerable<Order> EndExecute(AsyncCodeActivityContext context, IAsyncResult result)
{
// Get the DataServiceQuery from the context.UserState
DataServiceQuery<Order> ordersQuery = context.UserState as DataServiceQuery<Order>;
// Return an IEnumerable of the query results.
return ordersQuery.EndExecute(result);
}
}
다음 예제에서는 OrdersByCustomer 활동이 지정된 고객의 주문 목록을 검색한 다음 ForEach<T> 활동이 반환된 주문을 열거하고 각 주문의 날짜를 콘솔에 기록합니다.
Variable<IEnumerable<Order>> orders = new Variable<IEnumerable<Order>>();
DelegateInArgument<Order> order = new DelegateInArgument<Order>();
Activity wf = new Sequence
{
Variables = { orders },
Activities =
{
new WriteLine
{
Text = "Calling WCF Data Service..."
},
new OrdersByCustomer
{
ServiceUri = "http://services.odata.org/Northwind/Northwind.svc/",
CustomerId = "ALFKI",
Result = orders
},
new ForEach<Order>
{
Values = orders,
Body = new ActivityAction<Order>
{
Argument = order,
Handler = new WriteLine
{
Text = new InArgument<string>((env) => string.Format("{0:d}", order.Get(env).OrderDate))
}
}
}
}
};
WorkflowInvoker.Invoke(wf);
이 워크플로가 호출되면 다음 데이터가 콘솔에 기록됩니다.
Calling WCF Data Service...
8/25/1997
10/3/1997
10/13/1997
1/15/1998
3/16/1998
4/9/1998
참고 항목
OData 서버에 연결할 수 없는 경우 다음 예외와 유사한 예외가 발생합니다.
처리되지 않은 예외: System.InvalidOperationException: 이 요청을 처리하는 동안 오류가 발생했습니다. ---> System.Net.WebException: 원격 서버에 연결할 수 없습니다. ---> System.Net.Sockets.SocketException: 연결된 구성원으로부터 응답이 없어 연결하지 못했거나, 호스트로부터 응답이 없어 연결이 끊어졌습니다.
쿼리에서 반환된 데이터를 추가로 처리해야 하는 경우 활동의 EndExecute 재정의에서 이를 수행할 수 있습니다. BeginExecute 및 EndExecute 는 워크플로 스레드를 사용하여 호출되며 이러한 재정의의 모든 코드는 비동기적으로 실행되지 않습니다. 추가 처리가 광범위하거나 오래 실행되는 경우나 쿼리 결과가 페이징되는 경우 다음 단원에서 설명하는 방법을 고려해야 합니다. 이 방법에서는 대리자를 사용하여 쿼리를 실행하고 비동기적으로 추가 처리를 수행합니다.
대리자 사용
AsyncCodeActivity 기반 활동은 .NET Framework 클래스의 비동기 메서드를 호출할 뿐만 아니라 해당 메서드 중 하나에서 비동기 논리도 정의할 수 있습니다. 이 메서드는 활동의 BeginExecute 재정의에서 대리자를 사용하여 지정됩니다. 메서드가 반환될 때 런타임에서 활동의 EndExecute 재정의를 호출합니다. 워크플로에서 OData 서비스를 호출할 때 이 메서드를 사용하여 서비스를 쿼리하고 추가 처리를 제공할 수 있습니다.
다음 예제에서는 ListCustomers 활동을 정의합니다. 이 활동은 샘플 Northwind 데이터 서비스를 쿼리하고 Northwind 데이터베이스의 모든 고객이 포함된 List<Customer> 를 반환합니다. 비동기 작업은 GetCustomers 메서드에서 수행됩니다. 이 메서드는 서비스에서 모든 고객을 쿼리하여 List<Customer>에 복사합니다. 그런 다음 결과가 페이징되는지 확인하고 페이징되면 서비스에서 결과의 다음 페이지를 쿼리하여 목록에 추가하고 모든 고객 데이터가 검색될 때까지 계속합니다.
참고 항목
WCF Data Services의 페이징에 대한 자세한 내용은 방법: 페이지 단위 결과 로드(WCF Data Services)를 참조하세요.
모든 고객이 추가되면 목록이 반환됩니다. GetCustomers 메서드는 활동의 BeginExecute 재정의에 지정됩니다. 메서드에 반환 값이 있으므로 Func<string, List<Customer>> 가 메서드를 지정하기 위해 만들어집니다.
참고 항목
비동기 작업을 수행하는 메서드에 반환 값이 없는 경우 Action 대신 Func<TResult>이 사용됩니다. 두 방법을 모두 사용하여 비동기 예제를 만드는 예제는 동기 활동 만들기를 참조하세요.
이 Func<TResult>가 UserState에 할당된 다음 BeginInvoke가 호출됩니다. 호출될 메서드가 활동의 인수 환경에 액세스할 수 없으므로 ServiceUri 인수의 값이 BeginExecute에 전달된 콜백 및 상태와 함께 첫 번째 매개 변수로 전달됩니다. GetCustomers 가 반환되면 런타임에서 EndExecute를 호출합니다. EndExecute 의 코드에서는 UserState에서 대리자를 검색하고 EndInvoke를 호출하며 GetCustomers 메서드에서 반환된 고객의 목록인 결과를 반환합니다.
class ListCustomers : AsyncCodeActivity<List<Customer>>
{
[RequiredArgument]
public InArgument<string> ServiceUri { get; set; }
protected override IAsyncResult BeginExecute(AsyncCodeActivityContext context, AsyncCallback callback, object state)
{
// Create a delegate that references the method that implements
// the asynchronous work. Assign the delegate to the UserState,
// invoke the delegate, and return the resulting IAsyncResult.
Func<string, List<Customer>> GetCustomersDelegate = new Func<string, List<Customer>>(GetCustomers);
context.UserState = GetCustomersDelegate;
return GetCustomersDelegate.BeginInvoke(ServiceUri.Get(context), callback, state);
}
protected override List<Customer> EndExecute(AsyncCodeActivityContext context, IAsyncResult result)
{
// Get the delegate from the UserState and call EndInvoke
Func<string, List<Customer>> GetCustomersDelegate = (Func<string, List<Customer>>)context.UserState;
return (List<Customer>)GetCustomersDelegate.EndInvoke(result);
}
List<Customer> GetCustomers(string serviceUri)
{
// Get all customers here and add them to a list. This method doesn't have access to the
// activity's environment of arguments, so the Service Uri is passed in.
// Create the DataServiceContext using the service URI.
NorthwindEntities context = new NorthwindEntities(new Uri(serviceUri));
// Return all customers.
QueryOperationResponse<Customer> response =
context.Customers.Execute() as QueryOperationResponse<Customer>;
// Add them to the list.
List<Customer> customers = new List<Customer>(response);
// Is this the complete list or are the results paged?
DataServiceQueryContinuation<Customer> token;
while ((token = response.GetContinuation()) != null)
{
// Load the next page of results.
response = context.Execute<Customer>(token) as QueryOperationResponse<Customer>;
// Add the next page of customers to the list.
customers.AddRange(response);
}
// Return the list of customers
return customers;
}
}
다음 예제에서는 ListCustomers 활동이 고객의 목록을 검색한 다음 ForEach<T> 활동이 고객을 열거하고 각 고객의 회사 이름과 연락처 이름을 콘솔에 기록합니다.
Variable<List<Customer>> customers = new Variable<List<Customer>>();
DelegateInArgument<Customer> customer = new DelegateInArgument<Customer>();
Activity wf = new Sequence
{
Variables = { customers },
Activities =
{
new WriteLine
{
Text = "Calling WCF Data Service..."
},
new ListCustomers
{
ServiceUri = "http://services.odata.org/Northwind/Northwind.svc/",
Result = customers
},
new ForEach<Customer>
{
Values = customers,
Body = new ActivityAction<Customer>
{
Argument = customer,
Handler = new WriteLine
{
Text = new InArgument<string>((env) => string.Format("{0}, Contact: {1}",
customer.Get(env).CompanyName, customer.Get(env).ContactName))
}
}
}
}
};
WorkflowInvoker.Invoke(wf);
이 워크플로가 호출되면 다음 데이터가 콘솔에 기록됩니다. 이 쿼리가 많은 고객을 반환하므로 여기에서는 출력의 일부만 표시됩니다.
Calling WCF Data Service...
Alfreds Futterkiste, Contact: Maria Anders
Ana Trujillo Emparedados y helados, Contact: Ana Trujillo
Antonio Moreno Taquería, Contact: Antonio Moreno
Around the Horn, Contact: Thomas Hardy
Berglunds snabbköp, Contact: Christina Berglund
...
클라이언트 라이브러리를 사용하지 않고 OData 피드 사용
OData는 URI로 주소를 지정할 수 있는 리소스로 데이터를 노출합니다. 클라이언트 라이브러리를 사용할 때 이러한 URI가 자동으로 만들어지지만 클라이언트 라이브러리를 반드시 사용할 필요는 없습니다. 적절한 경우 클라이언트 라이브러리를 사용하지 않고 OData 서비스에 직접 액세스할 수 있습니다. 클라이언트 라이브러리를 사용하지 않는 경우 서비스의 위치와 원하는 데이터는 URI로 지정되며 결과가 HTTP 요청의 응답으로 반환됩니다. 그러면 이 원시 데이터를 원하는 방식으로 처리하거나 조작할 수 있습니다. OData 쿼리의 결과를 검색하는 한 가지 방법은 WebClient 클래스를 사용하는 것입니다. 이 예제에서는 ALFKI 키로 표현된 고객의 연락처 이름이 검색됩니다.
string uri = "http://services.odata.org/Northwind/Northwind.svc/Customers('ALFKI')/ContactName";
WebClient client = new WebClient();
string data = client.DownloadString(uri);
Console.WriteLine("Raw data returned:\n{0}", data);
이 코드가 실행되면 다음 출력이 콘솔에 표시됩니다.
Raw data returned:
<?xml version="1.0" encoding="utf-8" standalone="yes"?>
<ContactName xmlns="http://schemas.microsoft.com/ado/2007/08/dataservices">Maria Anders</ContactName>
워크플로에서 이 예제의 코드는 Execute 기반 사용자 지정 활동의 CodeActivity 재정의에 통합될 수 있지만, InvokeMethod<TResult> 활동을 사용하여 동일한 기능을 수행할 수도 있습니다. 워크플로 작성자는 InvokeMethod<TResult> 활동을 사용하여 클래스의 정적 메서드와 인스턴스 메서드를 호출할 수 있습니다. 이 활동에는 지정된 메서드를 비동기적으로 호출하는 옵션도 있습니다. 다음 예제에서는 InvokeMethod<TResult> 활동이 DownloadString 클래스의 WebClient 메서드를 호출하도록 구성되며 고객의 목록을 반환합니다.
new InvokeMethod<string>
{
TargetObject = new InArgument<WebClient>(new VisualBasicValue<WebClient>("New System.Net.WebClient()")),
MethodName = "DownloadString",
Parameters =
{
new InArgument<string>("http://services.odata.org/Northwind/Northwind.svc/Customers('ALFKI')/Orders")
},
Result = data,
RunAsynchronously = true
},
InvokeMethod<TResult> 는 클래스의 정적 메서드와 인스턴스 메서드를 모두 호출할 수 있습니다. DownloadString 은 WebClient 클래스의 인스턴스 메서드이므로 WebClient 클래스의 새 인스턴스가 TargetObject에 대해 지정됩니다. DownloadString 은 MethodName으로 지정되고, 쿼리가 포함된 URI는 Parameters 컬렉션에 지정되고, 반환 값은 Result 값에 할당됩니다. RunAsynchronously 값은 메서드 호출이 워크플로와 관련하여 비동기적으로 실행됨을 의미하는 true로 설정됩니다. 다음 예제에서는 InvokeMethod<TResult> 활동을 사용하여 샘플 Northwind 데이터 서비스에서 특정 고객의 주문 목록을 쿼리하는 워크플로가 생성되며 반환된 데이터가 콘솔에 기록됩니다.
Variable<string> data = new Variable<string>();
Activity wf = new Sequence
{
Variables = { data },
Activities =
{
new WriteLine
{
Text = "Calling WCF Data Service..."
},
new InvokeMethod<string>
{
TargetObject = new InArgument<WebClient>(new VisualBasicValue<WebClient>("New System.Net.WebClient()")),
MethodName = "DownloadString",
Parameters =
{
new InArgument<string>("http://services.odata.org/Northwind/Northwind.svc/Customers('ALFKI')/Orders")
},
Result = data,
RunAsynchronously = true
},
new WriteLine
{
Text = new InArgument<string>(env => string.Format("Raw data returned:\n{0}", data.Get(env)))
}
}
};
WorkflowInvoker.Invoke(wf);
이 워크플로가 호출되면 다음 출력이 콘솔에 표시됩니다. 이 쿼리가 몇 가지 주문을 반환하므로 여기에서는 출력의 일부만 표시됩니다.
Calling WCF Data Service...
Raw data returned:
<?xml version="1.0" encoding="utf-8" standalone="yes"?>*
<feed
xml:base="http://services.odata.org/Northwind/Northwind.svc/"
xmlns:d="http://schemas.microsoft.com/ado/2007/08/dataservices"
xmlns:m="http://schemas.microsoft.com/ado/2007/08/dataservices/metadata"
xmlns="http://www.w3.org/2005/Atom">
<title type="text">Orders\</title>
<id>http://services.odata.org/Northwind/Northwind.svc/Customers('ALFKI')/Orders\</id>
<updated>2010-05-19T19:37:07Z\</updated>
<link rel="self" title="Orders" href="Orders" />
<entry>
<id>http://services.odata.org/Northwind/Northwind.svc/Orders(10643)\</id>
<title type="text">\</title>
<updated>2010-05-19T19:37:07Z\</updated>
<author>
<name />
</author>
<link rel="edit" title="Order" href="Orders(10643)" />
<link rel="http://schemas.microsoft.com/ado/2007/08/dataservices/related/Customer" type="application/atom+xml;type=entry" title="Customer" href="Orders(10643)/Customer" />
...
이 예제에서는 워크플로 애플리케이션 작성자가 OData 서비스에서 반환된 원시 데이터를 사용하는 데 사용할 수 있는 한 가지 방법을 제공합니다. URI를 사용하는 WCF Data Services에 액세스하는 방법에 대한 자세한 내용은 데이터 서비스 리소스 액세스(WCF Data Services) 및 OData: URI 규칙을 참조하세요.
.NET