ティックデータからローソク足へのデータ変換と計算方法

ローソク足チャート（K線図）は、株式市場や金融取引でよく使用されるチャート形式であり、一定期間の始値、高値、安値、終値などの情報を表示します。本稿では、リアルタイムのティックデータを異なる時間足のローソク足データに変換する方法を紹介し、必要な数式と計算方法を提供することで、市場の動向をより良く分析・理解する手助けをします。

1. ローソク足チャートの概要

ローソク足チャートは、連続する矩形の棒で構成され、各矩形は特定の期間の価格変動を表します。各矩形には通常、始値（Open）、高値（High）、安値（Low）、終値（Close）の4つの主要な価格ポイントが含まれます。ローソク足の形状や組み合わせは、アナリストやトレーダーが市場のトレンドや価格パターンを識別するのに役立ちます。

2. リアルタイムティックデータ

リアルタイムティックデータとは、市場での個々の取引の価格と出来高の情報を指します。市場の流動性や価格変動について即時のフィードバックを提供します。リアルタイムティックデータには通常、タイムスタンプ、取引価格、取引数量などのフィールドが含まれます。

3. ローソク足データの計算方法

時間枠の設定
まず、ローソク足の時間足（各ローソク足が表す時間間隔）を決定する必要があります。例として、1分、15分、1時間などがあります。これにより、リアルタイムティックデータをサンプリングする時間間隔が決まります。

ローソク足データの計算
各時間枠内で、リアルタイムティックデータからローソク足の各価格ポイントを計算します。

• 始値（Open）：時間枠の最初のティックの価格。
• 高値（High）：時間枠内の最高価格。
• 安値（Low）：時間枠内の最低価格。
• 終値（Close）：時間枠の最後のティックの価格。

ローソク足データの更新
時間の経過に伴い、各時間枠はスライドし、新しいティックデータが計算範囲に入ります。各時間枠の終了時に、新しいティックデータに基づいてローソク足データを更新します。

その他の指標の計算
始値・高値・安値・終値に加えて、出来高や移動平均線などの他の指標をローソク足データから計算することもできます。これらの指標は、より深い市場分析を提供します。

4. 計算例

以下は、リアルタイムティックデータを1分足ローソク足データに変換する計算例です。

1. ローソク足データの初期化：
   • 初期始値：最初のティックの価格
   • 初期高値：最初のティックの価格
   • 初期安値：最初のティックの価格
   • 初期終値：最初のティックの価格
2. ローソク足データの更新：
   • 現在のティックのタイムスタンプが現在の時間枠内にない場合、時間枠が終了したことを意味し、ローソク足データを更新します。
   • 始値の更新：前の時間枠の終値（Previous Close）
   • 高値の更新：時間枠内の最高価格
   • 安値の更新：時間枠内の最低価格
   • 終値の更新：現在のティックの価格

上記は単純な例であり、実際の適用では、特定の要件を満たすために、より多くの詳細やデータ処理方法を検討する必要がある場合があります。

Javaコード例

import java.util.ArrayList;
import java.util.List;

public class KLineGenerator {
public static List<KLineData> generateKLineData(List<TickData> tickDataList, int interval) {
List<KLineData> kLineDataList = new ArrayList<>();
long startTime = tickDataList.get(0).getTime(); // Get the first tick's time as start time

// Initialize K-line data
long currentKLineStartTime = startTime - (startTime % interval);
double openPrice = tickDataList.get(0).getPrice();
double highPrice = openPrice;
double lowPrice = openPrice;
double closePrice = 0;
long volume = 0;

// Iterate through tick data
for (TickData tickData : tickDataList) {
long currentTime = tickData.getTime();
double currentPrice = tickData.getPrice();
long currentVolume = tickData.getVolume();

// If beyond the current K-line time period, generate a new K-line
if (currentTime >= currentKLineStartTime + interval) {
closePrice = tickDataList.get(tickDataList.indexOf(tickData) - 1).getPrice(); // previous tick's price as close

KLineData kLineData = new KLineData(currentKLineStartTime, openPrice, highPrice, lowPrice, closePrice, volume);
kLineDataList.add(kLineData);

// Reset K-line data for the new time period
currentKLineStartTime += interval;
openPrice = currentPrice;
highPrice = currentPrice;
lowPrice = currentPrice;
volume = currentVolume;
} else {
// Update K-line data
highPrice = Math.max(highPrice, currentPrice);
lowPrice = Math.min(lowPrice, currentPrice);
volume += currentVolume;
}
}

// Last tick's price as close
closePrice = tickDataList.get(tickDataList.size() - 1).getPrice();

// Generate the last K-line
KLineData lastKLineData = new KLineData(currentKLineStartTime, openPrice, highPrice, lowPrice, closePrice, volume);
kLineDataList.add(lastKLineData);

return kLineDataList;
}
}



// Tick data class
class TickData {
private long time;
private double price;
private long volume;

public TickData(long time, double price, long volume) {
this.time = time;
this.price = price;
this.volume = volume;
}

public long getTime() { return time; }
public double getPrice() { return price; }
public long getVolume() { return volume; }
}

// K-line data class
class KLineData {
private long time;
private double open;
private double high;
private double low;
private double close;
private long volume;

public KLineData(long time, double open, double high, double low, double close, long volume) {
this.time = time;
this.open = open;
this.high = high;
this.low = low;
this.close = close;
this.volume = volume;
}
// Getters and setters omitted
}

Pythonコード例

from datetime import datetime, timedelta

class TickData:
def __init__(self, time, price, volume):
self.time = time
self.price = price
self.volume = volume

class KLineData:
def __init__(self, time, open_price, high_price, low_price, close_price, volume):
self.time = time
self.open_price = open_price
self.high_price = high_price
self.low_price = low_price
self.close_price = close_price
self.volume = volume

def generate_kline_data(tick_data_list, interval):
kline_data_list = []
start_time = tick_data_list[0].time
current_kline_start_time = start_time - (start_time % interval)
open_price = tick_data_list[0].price
high_price = open_price
low_price = open_price
close_price = 0
volume = 0

for tick_data in tick_data_list:
current_time = tick_data.time
current_price = tick_data.price
current_volume = tick_data.volume

if current_time >= current_kline_start_time + interval:
close_price = tick_data_list[tick_data_list.index(tick_data) - 1].price
kline_data = KLineData(current_kline_start_time, open_price, high_price, low_price, close_price, volume)
kline_data_list.append(kline_data)

current_kline_start_time += interval
open_price = current_price
high_price = current_price
low_price = current_price
volume = current_volume
else:
high_price = max(high_price, current_price)
low_price = min(low_price, current_price)
volume += current_volume

close_price = tick_data_list[-1].price
last_kline_data = KLineData(current_kline_start_time, open_price, high_price, low_price, close_price, volume)
kline_data_list.append(last_kline_data)

return kline_data_list